是否有任何已实施的 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
到目前为止我发现的都是 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