org.springframework.xd.dirt.integration.kafka
Classes
IntegerEncoderDecoder
KafkaMessageBus