python-kafka：消費者可以根據消息屬性跳過消息嗎？

Question

給定一組消息，每個消息都有一個優先級屬性。消費者是否有可能跳過或忽略優先級屬性不夠高的消息？

起初，我對kafka-python使用者消費的消息進行了反序列化，檢查了優先級並丟棄了那些不符合所需優先級的消息。

但是我擔心如果消息很大，那麼浪費相當多的時間會對將不會進一步處理的消息進行反序列化。從卡夫卡隊列閱讀時是否沒有辦法做到這一點？

Answer 1

Kafka目前不支持這種自定義元數據，因此消費者篩選某些消息的唯一方法是讀取有效負載。然而，有一個improvement proposal under discussion這將解決這種情況，可能值得關注。