Package ai.pipestream.common.interceptor
package ai.pipestream.common.interceptor
-
ClassesClassDescriptionRuntime configurator for Kafka clients in SmallRye Reactive Messaging.Interceptor that automatically captures processing output to buffers based on @ProcessingBuffered annotation.