python-kafka：コンシューマはメッセージ属性に基づいてメッセージをスキップできますか？

Question

メッセージのセットが与えられ、それぞれが優先度属性を持ちます。消費者が優先度属性が十分に高くないメッセージをスキップまたは無視することは可能ですか？

最初は、kafka-pythonコンシューマが消費したメッセージをデシリアライズし、優先度レベルをチェックし、必要な優先度レベルを満たしていないメッセージを破棄しました。

しかし、私は、メッセージが大きければ、それ以上処理されないメッセージをデシリアライズするのにかなりの時間が浪費されることに懸念しています。カフカ・キューからの読み込み時にこれを行う方法はありませんか？

Answer 1

カフカはこのようにカスタムメタデータを現在サポートしていないため、消費者が特定のメッセージをフィルタリングする唯一の方法は、ペイロードを読み取ることです。しかし、このような状況に対処し、それに続く価値があるかもしれないimprovement proposal under discussionがあります。