Spring集成-Kafka消息驱动通道-自动确认

Question

我使用了spring io文档中列出的示例配置，它运行良好。

<int-kafka:message-driven-channel-adapter
        id="kafkaListener"
        listener-container="container1"
        auto-startup="false"
        phase="100"
        send-timeout="5000"
        channel="nullChannel"
        message-converter="messageConverter"
        error-channel="errorChannel" />

然而，当我用下游应用程序测试它时，我从Kafka那里消费并将其发布到下游。如果下游关闭，则消息仍在使用中，不会重播。

或者说，在使用kafka主题后，如果我在service activator中发现一些异常，我还想抛出一些异常，这些异常应该回滚事务，以便可以重播kafka消息。

简而言之，如果消费应用程序有一些问题，那么我想回滚事务，这样消息就不会被自动确认，除非成功处理，否则会被一次又一次地重播。

Answer 1

这不是Apache Kafka的工作方式。有类似于JMS的TX语义学。Kafka主题中的偏移与回弹或重新交付无关。

我建议您从他们的官方资源中更仔细地研究Apache Kafka。

Spring Kafka没有给常规Apache Kafka协议带来任何好处，但是您可以考虑使用Spring Kafka中的重试功能在本地重新传递相同的记录：http://docs.spring.io/spring-kafka/docs/1.2.2.RELEASE/reference/html/_reference.html#_retrying_deliveries

是的，ack模式必须是MANUAL，不要在消耗后自动将偏移量提交到Kafka中。