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。