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