Spring集成卡夫卡消息驱动通道适配器收到消息

Question

对于弹簧集成 - 卡夫卡版本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。