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

发布时间：2020-12-14 05:49:54 所属栏目：Java 来源：网络整理

导读：我正在与Kafka一起创建一个主管和事件管理系统.问题是我们得到了很多假的线索(广告).我们的系统中也有许多消费者.无论如何在去消费者之前过滤广告？我的解决方案是将所有内容写入第一个主题,然后由过滤器使用者读取,然后将其写回第二个主题或过滤它. 但我不

我正在与Kafka一起创建一个主管和事件管理系统.问题是我们得到了很多假的线索(广告).我们的系统中也有许多消费者.无论如何在去消费者之前过滤广告？
我的解决方案是将所有内容写入第一个主题,然后由过滤器使用者读取,然后将其写回第二个主题或过滤它.
但我不确定它是否有效.任何的想法？

你可以使用Kafka Streams( http://kafka.apache.org/documentation.html#streamsapi)和0.10.卡夫卡的版本.我认为这完全符合您的用例.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!