【发布时间】：2015-10-23 08:34:11
【问题描述】：
我正在尝试使用 spring-integration-kafka 抽象来实现 Kafka 消费者。有必要同步处理消息。
org.springframework.integration.kafka.listener.AcknowledgingMessageListener.java 是否同步处理消息？
【问题讨论】：
标签： spring-integration apache-kafka
【发布时间】：2015-10-23 08:34:11
【问题描述】：
实际上，您使用哪个MessageListener impl 并不重要。
KafkaMessageListenerContainer 保证将 Kafka 消息顺序传递给侦听器。当然来自同一个partition。
如果您使用 ExecutorChannel 将消息从您的 MessageListener 转移到另一个线程，我们无法帮助您保持秩序。
例如，如果您批量处理消息，则从另一侧可以acknowledge() 仅高于offsets。
【讨论】：