問題タブ [confluent-cloud]

Web Tracker、Scala Stream Kafka Collector、Stream Enrich、Druid、および Metabase を使用して、Docker 内で動作するエンド ツー エンドのローカル実装を取得することができました。

Helm を使用して Kubernetes 内で動作するステージング環境を構築する前に、Scala Stream Kafka Collector を Kafka Confluent Cloud アカウントに接続してみました。ただし、SASL 認証で問題が発生しています。この件に関するドキュメントはかなりまばらで、Kafka のドキュメントを示しているだけです。これが私のconfig.hocon構成です-

ただし、コンテナが起動すると、出力の構成が一致しません -

さらに、コンソールに次のエラーが表示されます -

通常のチャネルでヘルプを検索しているときに、このエラーは JAAS 構成がプロデューサーに表示されないことが原因であることが示唆されているため、これは単に私の側の構成の問題であると確信しています。何かが欠けていない限り、構成オプションが使用可能であることを構成が示唆しているため、プロデューサで SASL 認証が使用可能であることが期待されます。

誰もこの問題の経験がありますか?

コンフルエントで作業していて、MySQL をソースとして接続しようとしましたが、接続されましたが、スノーフレークに接続しようとすると、リージョン エラーが発生します。

ここに、コンフルエントのコネクタ構成があります

エラーは次のとおりです。

同じリージョンで試しましたが、役に立ちませんでした。助けてください、よろしくお願いします。

2 つの異なる API を介してイベントを kafka に発行する例を試しています。1 つは作成イベントを取得し、もう 1 つは同じトピック ユーザーの更新イベントを取得します。

これらの API はどちらも、異なるスキーマを持つ同じ kafka トピックにメッセージを発行します。

基本的に UserCreated、UserUpdated スキーマがユーザー トピックに公開されます。

コンシューマーは UserUpdated イベントのみに関心があるため、TopicRecordNameStrategy をサポートするコンシューマーをどのようにセットアップできるか疑問に思っています。現在、ユーザーのトピックをリッスンしている 2 つのコンシューマーがいて、両方ともメッセージを受信して​​います。

プロデューサーとコンシューマーの両方が同じサービスにあるコンフルエントなカフカに接続するサンプル スプリング ブート アプリを作成しました

作成と更新のための 2 つのエンドポイントをサポートする REST API があります。この残りの API はプロデューサーにメッセージを発行します

これが私のコードです。

アプリケーションyml

RestController.java

Producer.java

コンシューマ.java

出力