Interface | Description |
---|---|
ConsumerActions<K,V> |
Simple consumer actions.
|
ConsumerActions.DynamicAssignment<K,V> |
Implementation of actions that allow dynamic assignment of topic/partitions.
|
ProducerActions<K,V> |
Class | Description |
---|---|
AsyncProducer<K,V> |
An async wrapper for kafka producer that is resilient in the event of failures - it recreates the underlying
kafka producer when unrecoverable error occurs.
|
ConsumerChainedExceptionHandler | |
ConsumerContainer<K,V> |
A single-threaded Kafka Consumer container that is able to
ConsumerContainer.submit(Function) actions
from other threads to be executed asynchronously in the single consumer thread. |
ConsumerContainer.DynamicPool<K,V> |
A dynamic pool of
ConsumerContainer s (typically configured with the same group.id)
sized dynamically by ConsumerContainer.DynamicPool.setConsumerThreads(int) |
ConsumerSkipRecordsSerializationExceptionHandler | |
Oneof2<FST,SND> |
Either 1st or 2nd.
|
ProtoSerde<M extends com.google.protobuf.MessageLite> | |
SelfSerde<T> | |
Submitter |
Enum | Description |
---|---|
Seek |
Consumer seek options.
|
Copyright © 2020 Red Hat. All rights reserved.