到目前为止,我发现的都是PollableChannel / PollableConsumer实现,例如:https://github.com/spring-projects/spring-integration-samples/blob/master/basic/kafka我还需要继续搜索吗?对于Kafka消费者而言,所有事件驱动的渠道都有意义吗?
请参阅Spring中的Apache Kafka文档的spring-integration-kafka Chapter。
Spring Integration Kafka现在基于Spring for Apache Kafka项目。它提供以下组件:
出站通道适配器
消息驱动的通道适配器
入站通道适配器
出站网关
入站网关
由Kafka主题支持的频道