org.springframework.integration.kafka.inbound
Classes 
KafkaHighLevelConsumerMessageSource
KafkaMessageDrivenChannelAdapter