See: Description
| Interface | Description |
|---|---|
| Consumer<K,V> | |
| ConsumerInterceptor<K,V> |
A plugin interface that allows you to intercept (and possibly mutate) records received by the consumer.
|
| ConsumerRebalanceListener |
This feature is not yet supported.
|
| OffsetCommitCallback |
A callback interface that the user can implement to trigger custom actions when a commit request completes.
|
| Class | Description |
|---|---|
| ConsumerConfig |
The consumer configuration keys
|
| ConsumerRecord<K,V> |
A key/value pair to be received from TxEventQ.
|
| ConsumerRecords<K,V> |
A container that holds the list
ConsumerRecord per partition for a particular topic. |
| KafkaConsumer<K,V> |
Note: Topic name has to be in uppercase wherever used.
|
| OffsetAndMetadata |
This feature is not yet supported.
|
| OffsetAndTimestamp |
A container class for offset and timestamp.
|
| Enum | Description |
|---|---|
| OffsetResetStrategy |
This feature is not yet supported
|