我們是否可以收聽Kafka Consumer的特定鍵控訊息

Question

我對Kafka非常陌生。我有一個要求，我只需要閱讀一些特定的消息。

爲此，我會用一些關鍵和價值向卡夫卡發消息。有沒有一種方法可以讓消費者訂閱特定的密鑰列表。因此，當消息被推送到Kafka時，如果消息具有消費者正在傾聽的密鑰，則消費者將消費。

Answer 1

我能想到的唯一方法是，您可以將消費者分配給發行商使用您感興趣的密鑰發送消息的分區。您還需要編寫自己的分區器，這將允許您用密鑰X總是將消息發送到同一個分區。

更簡單的方法：用一種只處理消息的方式編寫消費者。