我们可以通过Kafka Consumer收听特定的关键消息吗?

Question

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

为此，我将向Kafka推送一个带有一些键和值的消息。是否有一种方法可以将消费者订阅到特定的键列表?这样，当消息被推送到Kafka时，如果消息有一个消费者正在监听的键，消费者就会消费。

Answer 1

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

更简单的方法是:编写一个消费者，让它只处理你想要的消息。