| Name | Description | Type | Package | Framework |
| IntegerEncoderDecoder | A Kafka encoder / decoder used to serialize a single int, used as the kafka partition key. | Class | org.springframework.xd.dirt.integration.kafka | Spring XD |
| KafkaMessageBus | A message bus that uses Kafka as the underlying middleware. | Class | org.springframework.xd.dirt.integration.kafka | Spring XD |
| KafkaMessageBus .Mode | Class | org.springframework.xd.dirt.integration.kafka.KafkaMessageBus | Spring XD | |
| KafkaMessageBus .OffsetManagement | Class | org.springframework.xd.dirt.integration.kafka.KafkaMessageBus | Spring XD | |