用于春季融合-Kafka版本2.1.0.Release,文档似乎已过时
DOC中的示例是不正确的,因为它与> 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>
对不起;我们将修复文档;正确的文档在快速启动部分中。