| Class | Description |
|---|---|
| IntegerEncoderDecoder |
A Kafka encoder / decoder used to serialize a single int, used as the kafka partition key.
|
| KafkaMessageBus |
A message bus that uses Kafka as the underlying middleware.
|
| Enum | Description |
|---|---|
| KafkaMessageBus.Mode | |
| KafkaMessageBus.OffsetManagement |