| Class | Description |
|---|---|
| ConsumerRecords |
Helper class use to deserialize the ConsumerService responses of consume() requests.
|
| ConsumerRecords.ConsumerRecord |
Helper class containing all attributes of a consumed record.
|
| ConsumerRecords.ConsumerRecordMessage |
Headers and payload of the consumed record.
|
| ConsumerRecords.ConsumerRecordRoutingData |
Topic name and sharding key of the consumed record.
|
| ConsumerServiceError |
ConsumerServiceError is a helper class used to parse the JSON object returned by Consumer Service when an error
has occurred.
|
| ProducerRecords |
ProducerRecords is the parameter type used in
Channel.produce(ProducerRecords). |
| ProducerRecords.ProducerRecord |
Helper class containing all attributes and inner classes of a produce record.
|
| ProducerRecords.ProducerRecord.Builder |
ProducerRecords.ProducerRecord.Builder is a helper class implementing the builder pattern to easily create ProducerRecords.ProducerRecord
objects. |
| ProducerRecords.ProducerRecord.Message |
Message is a class that contains the payload to produce (mandatory attribute) and a map of headers (optional
attribute)
|
| ProducerRecords.ProducerRecord.RoutingData |
RoutingData is a class that contains the topic to produce to (mandatory value) and the shardingKey (optional
attribute)
|
| Topics |
Helper class used to serialize and deserialize a list of topic names
|