java – 如何在将消息传递给消费者之前过滤消息?

前端之家收集整理的这篇文章主要介绍了java – 如何在将消息传递给消费者之前过滤消息?前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
我正在与Kafka一起创建一个主管和事件管理系统.问题是我们得到了很多假的线索(广告).我们的系统中也有许多消费者.无论如何在去消费者之前过滤广告?
我的解决方案是将所有内容写入第一个主题,然后由过滤器使用者读取,然后将其写回第二个主题或过滤它.
但我不确定它是否有效.任何的想法?

解决方法

你可以使用Kafka Streams( http://kafka.apache.org/documentation.html#streamsapi)和0.10.卡夫卡的版本.我认为这完全符合您的用例.
原文链接:https://www.f2er.com/java/121109.html

猜你在找的Java相关文章