0
質問の設定を取得する方法:カフカのブートストラップコンフィギュレーションカフカコネクタからカフカの専門家のための
を誰もがSinkConnectorまたはSinkTaskのいずれかから、労働者のコンフィグ設定「bootstrap.servers」を取得する方法を知っていますか?または、カフカクラスター情報をコネクターから取得する方法は?
ありがとうございました
質問の設定を取得する方法:カフカのブートストラップコンフィギュレーションカフカコネクタからカフカの専門家のための
を誰もがSinkConnectorまたはSinkTaskのいずれかから、労働者のコンフィグ設定「bootstrap.servers」を取得する方法を知っていますか?または、カフカクラスター情報をコネクターから取得する方法は?
ありがとうございました
AFAIK、Connect APIは現在この情報を提供していません。 この機能が必要な場合は、おそらく、Apache KafkaプロジェクトでJIRAを開き、ユースケース(この情報をどのように計画しているか)を説明することをお勧めします。
ありがとうございます、Gwen、ご返信ありがとうございます。ユースケースは、メッセージをエラートピックにリダイレクトするのはかなり簡単です。現時点では、私の回避策は、いくつかのメッセージをエラートピックに転送するプロデューサの追加の設定を設定することです(SQLエラーが発生した場合など)。 –
ああ、それを持っています!私たちは、フレームワークにエラー処理を組み込むことに取り組んでいます。そのため、コネクタで行う必要はありません。 –
恐ろしい!この機能を持つことは素晴らしいことです。 –