Spring Integration Kafka 消息驱动通道适配器接收消息

Question

对于 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>

Answer 1

对此感到抱歉；我们将修复文档；正确的文档在quick start section。