カフカからの肯定応答（スプリング統合による）

Question

春の統合カフカ（2.1）を使用して、カフカのトピックにメッセージを正常に送信することができました。

ネイティブのKafkaクライアントAPIは、送信成功時にコールバックのオプションを提供します。 Spring統合 - Kafkaでこれをどうすれば実現できますか？下記の私の設定とコードを参考にしてください。

XML構成

<int:publish-subscribe-channel id="inputToKafka" /> 

    <int-kafka:outbound-channel-adapter id="kafkaOutboundChannelAdapter" 
             auto-startup="true" 
             channel="inputToKafka" 
             kafka-template="template" 
             topic="test" 
             sync="true"> 
    </int-kafka:outbound-channel-adapter> 

    <bean id="template" class="org.springframework.kafka.core.KafkaTemplate"> 
     <constructor-arg> 
      <bean class="org.springframework.kafka.core.DefaultKafkaProducerFactory"> 
       <constructor-arg> 
        <map> 
         <entry key="bootstrap.servers" value="localhost:9092" /> 
         <!--<entry key="retries" value="0" /> 
         <entry key="batch.size" value="16384" /> 
         <entry key="linger.ms" value="0" /> 
         <entry key="buffer.memory" value="33554432" /> --> 
         <entry key="key.serializer" 
           value="org.apache.kafka.common.serialization.StringSerializer" /> 
         <entry key="value.serializer" 
           value="org.apache.kafka.common.serialization.StringSerializer" /> 
        </map> 
       </constructor-arg> 
      </bean> 
     </constructor-arg> 
    </bean> 

のJavaコードメッセージに

@Autowired 
    @Qualifier("inputToKafka") 
    MessageChannel channel; 

channel.send(MessageBuilder.withPayload("Test Message").build()); 

Answer 1

を送信するために存在し、 "メッセージング" は、現在ではありません - バックスタイルの呼び出しは、しかし、あなたはKafkaTemplateとProducerListenerを登録することができます。 KafkaTemplateを参照してください。