我们是否可以收听Kafka Consumer的特定键控讯息

Question

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

为此，我会用一些关键和价值向卡夫卡发消息。有没有一种方法可以让消费者订阅特定的密钥列表。因此，当消息被推送到Kafka时，如果消息具有消费者正在倾听的密钥，则消费者将消费。

Answer 1

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

更简单的方法：用一种只处理消息的方式编写消费者。