我们可以收听 Kafka Consumer 的特定键控消息吗

Question

我对卡夫卡非常陌生。我有一个要求，我只需要阅读一些特定的消息。

为此，我将向 Kafka 推送一条带有一些键和值的消息。有没有一种方法可以让消费者订阅特定的密钥列表。因此，当消息推送到 Kafka 时，如果消息具有消费者正在侦听的密钥，则消费者将进行消费。

Answer 1

我能想到的唯一方法是您可以将您的消费者分配给发布者使用您感兴趣的密钥向其发送消息的分区。您还需要编写自己的分区程序，这将允许您发送带有键 X 的消息总是发送到同一个分区。

更简单的方法：编写一个只处理你想要的消息的消费者。