是否有任何已实施的 SubscribableChannel/EventDrivenConsumer 可用于 Spring 集成 Kafka 消费者?

Is there any implemented SubscribableChannel/EventDrivenConsumer out there to be used in a Spring Integration Kafka consumer?

到目前为止我发现的都是 PollableChannel/PollableConsumer 实现,例如: https://github.com/spring-projects/spring-integration-samples/blob/master/basic/kafka 我还需要继续寻找吗? 对于 Kafka 消费者来说,事件驱动的渠道是否有意义?

请参阅 Apache Kafka 文档 Spring 中的 spring-integration-kafka Chapter

Spring Integration Kafka is now based on the Spring for Apache Kafka project. It provides the following components:

Outbound Channel Adapter

Message-driven Channel Adapter

Inbound Channel Adapter

Outbound Gateway

Inbound Gateway

Channels Backed by Kafka Topics