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 | |