我正在使用 Kafka 创建一个线索和事件管理系统。问题是我们收到了很多假线索(广告)。我们的系统中也有很多消费者。有没有办法在到达消费者之前过滤广告？ 我的解决方案是将所有内容写入第一个主题，然后由过滤器消费者读取，然后将其写回第二个主题或对其进行过滤。 但我不确定它是否有效。有什么想法吗？
最佳答案
您可以将 Kafka Streams ( http://kafka.apache.org/documentation.html#streamsapi ) 与 0.10.+ 版本的 Kafka 一起使用。我认为这完全适合您的用例。
关于java - 如何在将消息传递给消费者之前对其进行过滤？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30915302/