問題タブ [strimzi]

Strimzi kafkaconnect クラスターで実行されている 13 個の kafka debezium postgres コネクタがあります。そのうちの 1 つが で失敗していCaused by: java.lang.OutOfMemoryError: Java heap spaceます。jvm オプションを 2g から 4g に増やしましたが、それでも同じ問題で失敗します。

完全なログ:

この時点では、私はこのプラットフォームにあまり詳しくありませんので、ご容赦ください。私の Devops チームは、 k8s の docker コンテナーに kafka connect サービス インスタンスを strimzi を使用してセットアップしました。接続サービスは正常に動作しているように見えますが、常に (30 秒ごとに) 次のエラーをログに記録しています。

それをセットアップしたチームは、それを修正する方法を理解できないと私に言いました. それほど害はないように見えますが、1) ログが乱雑で、2) サービスの構成が明らかに間違っていることに満足していません。ドキュメントをいくつか見ましたが、TBH、この時点で少し迷っています。

誰かがこの動作に精通している場合は、これを修正する方法の参照を教えてもらえますか? ありがとう、JS

Kafka elasticsearch コネクタ「confluentinc-kafka-connect-elasticsearch-5.5.0」はオンプレミスでは機能しません。

同じパスで mssql コネクタと s3 コネクタ プラグインも使用しています。それらは機能しますが、elasticsearch プラグインで noclassfound エラーが発生します。これはワーカーの私のフォルダー構造です:

いくつかのメッセージを読みましたが、elasticsearch コネクタに jar ファイルや依存関係がありません。上記のように追加しましたが、うまくいきませんでした。

これは私のコネクタ構成です:

ユーザー名/パスワードを平文に変更しました。運がない。私はelasticsearch接続のためにhttp/httpsの両方を試しましたが、うまくいきませんでした。

これは私のelasticsearch srv情報です：

両方の方法で Kafka Connect Worker からエラスティック検索サービスに接続できます。

私が何をしても、例外はまったく変わりません。他に試すことができるものがあるかどうかはわかりません。私の脳は燃えている、私は夢中になろうとしている.

何か足りないものはありますか? または、このコネクタを Kubernetes のオンプレミスで実行する方法を教えていただけますか?

ありがとうございます。それでは、お元気で