メッセージキーを知っている場合、Kafkaコンパクトトピックから単一のメッセージを読み取ることは可能ですか？
コンシューマーJavadocには、機能するように見えるものは何も見つかりませんでした。
Kafkaトピックはキーにインデックス付けされておらず、キーによってパーティション化されています。
はい、圧縮に関係なく単一のメッセージを読むことはできますが、特定のキーから始まるトピックを読むことはできず、オフセットのみを読むことができます。
キーを知っていると、パーティションを見つけることができます（デフォルトのパーティショナーを使用していると仮定します）。
しかし、それが最善の方法です...パーティション全体をスキャンして、キーのオフセットを見つける必要があります
たとえば、kafkacatを使用して、キーとオフセットを印刷します
kafkacat -C -b kafka:9092 -t topic-name -p 0 -f "key: %k; offset: %o\n" | grep key-value
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加