Kafka有效的方法可以忽略自我产生的消息
kafka efficient way to ignore self produced messages
我刚刚开始学习kafka。我有一个可以运行多个实例的应用程序。
每个实例都有生产者和消费者。每个实例请求数据通过使用Producer API发送消息和其他方式都应通过消费者API接收消息。
现在,因为只有一个主题正在交换数据,并且每个实例都是同一主题的生产者和消费者,所以同一实例获得了自我创建的消息。这是一种预期的行为。
我的问题:忽略在给定应用程序实例上自我创建的消息的有效方法是什么?
我正在使用Linux Box上的C librdkafka库。
也许您可以将应用程序ID(作为生产者应用程序的ID(嵌入到交货时检查的消息中,并且如果该ID与接收应用程序的ID匹配。
相关文章:
- boost::进程间消息队列引发错误
- 在线编译器中的分段C++没有打印消息
- C++错误消息*成员参考.**初学者*
- 在createdialog创建的窗口中捕获用于编辑控件的OnMouseMove消息
- 要与"if constexpr"一起使用的编译时消息(在预处理器之后)
- 如何通过参数抛出错误消息
- 从服务器传输到客户端的消息不会出现
- ROS2 动态消息模板
- C++秘密消息学校作业
- glad 导致 glfwSwapBuffers 返回错误消息
- C++入门 5 版:类消息和文件夹
- FindPackageHandleStandardArgs.cmake:137 的 CMake 错误(消息):找不到 Boost (缺少:正则表达式)(找到合适的版本"1.72.0",
- 如何处理从一个对象传递到另一个在C++中具有公共抽象类的对象的消息
- 如何接受 [ENTER] 键作为无效输入并发送错误消息
- 由于无效的 ValidateRgn() 子窗口不会收到WM_PAINT消息
- "string.h"在构建适用于iOS的qt应用程序中找不到消息
- 如何将 Firebase 与基于 Linux 的客户端应用配合使用,以便与服务器进行双向消息通信
- 重新定义预定义的 errno 错误消息 (E2BIG)
- Kafka有效的方法可以忽略自我产生的消息
- 如何拦截来自我的 CDialog 的WM_SIZE消息