Package org.springframework.xd.dirt.integration.kafka

Class Summary

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.