Kafka有效的方法可以忽略自我产生的消息

kafka efficient way to ignore self produced messages

本文关键字:自我 消息 有效 方法 Kafka      更新时间:2023-10-16

我刚刚开始学习kafka。我有一个可以运行多个实例的应用程序。

每个实例都有生产者和消费者。每个实例请求数据通过使用Producer API发送消息和其他方式都应通过消费者API接收消息。

现在,因为只有一个主题正在交换数据,并且每个实例都是同一主题的生产者和消费者,所以同一实例获得了自我创建的消息。这是一种预期的行为。

我的问题:忽略在给定应用程序实例上自我创建的消息的有效方法是什么?

我正在使用Linux Box上的C librdkafka库。

也许您可以将应用程序ID(作为生产者应用程序的ID(嵌入到交货时检查的消息中,并且如果该ID与接收应用程序的ID匹配。