| Interface | Description |
|---|---|
| ConsumerRebalanceListener |
A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the
consumer changes.
|
| DatabusPushConsumerListener<P> |
This is the interface that SDK Databus client has to implement to receive and process records
when consume them by using a
DatabusPushConsumer instance. |
| OffsetCommitCallback |
A callback interface that the user can implement to trigger custom actions when a commit request completes.
|
| Class | Description |
|---|---|
| Consumer<P> |
A abstract consumer, responsible for handling Databus incoming messages.
|
| ConsumerConfiguration | |
| ConsumerRecord<P> |
It represents a consumer record created by a
DatabusConsumer when a new incoming message comes up. |
| ConsumerRecords<P> |
This class contains a set of
ConsumerRecord. |
| DatabusConsumer<P> |
It consumes records listening to a set of topics that were published for a
DatabusProducer |
| DatabusPushConsumer<P> |
Extends a
DatabusConsumer to replace poll model for push message model. |
| DatabusPushConsumerFuture |
This class allows SDK Databus client to know the status of a
DatabusPushConsumer instance |
| DatabusPushConsumerStatus |
This class tracks DatabusPushConsumer internal status
DatabusPushConsumerStatus.Status and
let the user knows how is going on the internal message listener processor
DatabusPushConsumerListenerResponse |
| NoOpConsumerRebalanceListener |
A non-functional implementation of
ConsumerRebalanceListener |
| OffsetAndMetadata |
The Kafka offset commit API allows users to provide additional metadata (in the form of a string)
when an offset is committed.
|
| Enum | Description |
|---|---|
| DatabusPushConsumerListenerResponse | |
| DatabusPushConsumerStatus.Status |
DatabusPushConsumer Status
|