对于 spring-integration-kafka 版本 2.1.0.RELEASE,documentation似乎已经过时了
文档中的示例不正确,因为它与 KafkaMessageListenerContainer 的构造函数参数不匹配。有人可以指导我如何正确创建 bean 以及相应的 Java 代码来处理消息吗?
<bean id="container1" class="org.springframework.kafka.listener.KafkaMessageListenerContainer">
<constructor-arg>
<bean class="org.springframework.kafka.core.DefaultKafkaConsumerFactory">
<constructor-arg>
<map>
<entry key="bootstrap.servers" value="localhost:9092" />
</map>
</constructor-arg>
</bean>
</constructor-arg>
<constructor-arg name="topics" value="foo" />
</bean>
最佳答案
对此感到抱歉;我们将修复文档;正确的文档位于 quick start section .
关于java - Spring Integration Kafka消息驱动 channel 适配器接收消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41137034/