Mule Anypoint studio Kafka 连接器 - 消费者无法接收消息答案

【问题标题】：Mule Anypoint studio Kafka Connector - Consumer is not able to receive messagesMule Anypoint studio Kafka 连接器 - 消费者无法接收消息
【发布时间】：2019-08-22 18:11:11
【问题描述】：

Mule 应用（Any Point Studio 应用）正在消费 API 应用通过 Kafka 发布的消息，

但是 Mule(Any Point Studio) Kafka Consumer 无法接收消息。每次我停止启动应用程序以使用消息时，即使我们这样做，我们也会收到旧消息，包括新消息，

使用Mule 3.9版本，kafka-client ‎0.10.0.0

我尝试在 consumer.properties 文件中添加一些属性，例如 poll。

Consumer.Properties having below code,
group.id=user
auto.offset.reset=earliest
enable.auto.commit=false

Consumer.Properties having below code,

group.id=user

在 Any point studio flow 中，Kafka Connector [Consumer] -> 给定主题名称为 customer_data，分区为 1。没有提供任何偏移量

我希望消费者应该在不重新启动应用程序的情况下阅读消息，并且不应该再次收到旧消息

【问题讨论】：

标签： mule kafka-consumer-api mule-studio mule-component

【解决方案1】：

问题在于，如果您的 enable.auto.commit 为 true，mule 只会管理偏移量。保持真实是个坏主意，因为即使您的 muleflow 失败，它也会提交偏移量。所以你通过禁用它做了正确的事情。

问题来了 - 在 enable.auto.commit=false 之后，您基本上应该自己管理偏移量。我遇到了类似的问题，正在考虑创建自定义类，该类将在 mule 流成功执行后显式调用 sync()。

【讨论】：