4

ユースケースは以下のとおりです。 Javaコード内の多くのオブジェクトインスタンスに対して、プロデューサまたはコンシューマ参照を渡しています。 そのうちのいくつかでは、カフカ設定のチェックをしたいと思います。 私は、どのような効果的な設定がKafka Producer/Consumer(デフォルトを含む)に格納されているかを知りたいと考えています。 私は、Javaのドキュメントに明示的anthingが表示されていない。Kafkaのプロデューサとコンシューマの設定(Java API)を取り戻すには?

だから、どのようにバックカフカの生産者と消費者の設定をを取得するには?

答えて

3

残念ながら、それは不可能です。私は、少なくとも "コア"構成プロパティを表示するのに便利な機能であることを認めなければなりません(例えば、認証のための "秘密"を得る可能性を避ける)。 今日私が見る唯一の解決策は、コンシューマ/プロデューサインスタンスと、クライアント構成の設定に使用される関連プロパティバッグとの間にリンクを設定することです。私はそれがクライアントの内部にあるので、それはメモリの無駄だと理解していますが、あなたはそれを持っているあなたのプロパティバッグを維持する必要があります。

+0

お返事ありがとうございます。 ** my ** configの問題は、istは私のものです:-)、Producer/Consumerから切り離すことができます。 アプリケーションサーバーがある場合、Beanが多く、同じプロデューサ/コンシューマを使用しています。 プロデューサが作成されたときの設定は1回だけ作成されたか、または新しい「KafkaProducer/Consumer」の重複がありました。もちろん、完璧なソフトウェアではすべてが明確であり、うまくいきます。しかし時々私はバグを持っています:-)現在の設定をdebbugingするのは難しく、簡単に設定をログに記録したり、いくつかの検証機能を準備するだけです。 –