与えられた一連のメッセージが与えられ、それぞれに優先度属性があります。優先度属性が十分に高くないメッセージを消費者がスキップまたは無視することは可能ですか?
最初に、kafka-python コンシューマによって消費されるメッセージをデシリアライズし、優先度レベルをチェックして、必要な優先度レベルを満たしていないメッセージを破棄しました。
しかし、メッセージが大きい場合、それ以上処理されないメッセージを逆シリアル化するためにかなりの時間が浪費されるのではないかと心配しています。カフカキューからの読み取り時にこれを行う方法はありませんか?