Kafka对《生产与spring-整合》的肯定

Question

使用spring集成Kafka(2.1)，我能够成功地发送消息到Kafka的一个主题。

本机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。