【发布时间】：2019-11-24 14:49:39
【问题描述】：
我有一项服务可以计算帐户的信誉分数。它将计算结果放入名为“ReputationScores”的 Kafka 主题中。每条消息如下所示：
{ "account" : 12345, "repScore" : 98765}
我希望我的消费者能够仅使用特定帐户的这些消息。
例如，我想让一个消费者实例仅消费帐户 12345 的主题为“ReputationScore”的消息。该实例可能应该是其消费者组的唯一成员。
Kafka 可以根据消息内容进行过滤吗？最好的方法是什么？
感谢您的帮助。
【问题讨论】：
-
您可以使用自定义分区器创建特定于 12345 的分区，并将 cosumer 分配给该分区，而不是订阅主题。
-
你的意思是你想从你的消费者的主题中为任意帐户的值进行 k/v 查找？或者您希望消费者的给定实例处理给定帐户，但要处理所有消息？
-
@A.Dev，谢谢。我会检查一下。
-
@Robin，我已经用一个例子更新了这个问题。感谢您的帮助。
-
对使用
spring Kafka有任何想法吗？我相信你知道卡夫卡偏移确认@JonathanM
标签： apache-kafka kafka-consumer-api