照会カフカメッセージ

Question

は、私はmessage.valueが私のプロデューサーで

を送信する前にカフカにすでに存在しているかどうかを検出する必要がapplication.Forこれをストリーミング私の火花でカフカのメッセージプロデューサ（KafkaProducer）を持ってあります私はカフカのメッセージを照会することができるので、任意のツールですか？私はメッセージを消費したいのではなく、既存のメッセージを照会するだけです。

Answer 1

短い答え：これはカフカ機能を内蔵しているため不可能です。

あなたは、現在のユースケースでこのような機能が必要な理由を説明することができます。あなたがやりたいことを達成するための他の方法があるかもしれません。

Answer 2

値を挿入する前にキーを検索する必要がある場合は、HbaseまたはMongoDB、またはその他のオプションElasticsearch、Cassandraを使用する必要があります。 カフカはデータバッファで、システムのデカップリングを目的としています。 正しい方法でテクノロジを使用する必要があります。