Package io.streamthoughts.azkarra.api.events
-
Interface Summary Interface Description BlockingRecordQueue<K,V> A blocking queue that can be used for publishing key-value records from a Kafka Streams topology.EventStreamPipe<K,V> The EventStreamPipe is used to attached or detach an object that will be responsible to consume records send to anEventStream
.EventStreamProvider EventStreamsProvider.LimitHandler The default interface to be used for executing logic when buffer limit is reached. -
Class Summary Class Description BasicBlockingRecordQueue<K,V> A simpleBlockingRecordQueue
backed by aBlockingQueue
.DelegateBlockingRecordQueue<K,V> A delegatingBlockingRecordQueue
that can be used to easily override some methods.EventStream<K,V> A typed stream of events backed by aBlockingRecordQueue
.EventStream.Builder EventStreamSupport Base class forEventStreamProvider
.LimitHandlers Provides built-inLimitHandler
implementation. -
Exception Summary Exception Description LimitHandler.BlockingQueueLimitReachedException