Package ai.pipestream.common.interceptor


package ai.pipestream.common.interceptor
  • Classes
    Class
    Description
    Runtime configurator for Kafka clients in SmallRye Reactive Messaging.
    Interceptor that automatically captures processing output to buffers based on @ProcessingBuffered annotation.