問題タブ [confluent-schema-registry]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

824 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
398 参照

apache-kafka - avro スキーマで java.util.List を使用して Kafka からメッセージを読み取る

次のプロパティを持つコンシューマーを使用して、カフカからメッセージを読み取ろうとしています

そしてスキーマは

オブジェクトは、このスキーマを使用して Kafka に正常に書き込まれました。しかし、逆シリアル化で例外が発生しますjava.lang.NoSuchMethodException: java.util.List.<init>()

java.util.List クラスを使用することは可能ですか? コンフルエントな 3.1.2 を使用しています

0 投票する
1 に答える
14746 参照

apache-kafka - ID 1 の Avro スキーマの取得中にエラーが発生しました。サブジェクトが見つかりません。; エラーコード: 40401

コンフルエント バージョン 4.1.0

KTable を使用していくつかのトピック (topic_1、topic_2) からデータを消費し、データを結合してから、KStream を使用して別のトピック (topic_out) にデータをプッシュしています。(Ktable.toStream())

データは avro 形式です

を使用してスキーマを確認すると

私は見つける

しかし、topic_out-key を持つサブジェクトはありません。なぜ作成されないのですか？

topic_out からの出力:

キーが生成されていることがわかりますが、キーのサブジェクトはありません。

サブジェクトとキーが必要なのはなぜですか?
このトピックを別のコネクタ (hdfs-sink) にフィードしてデータを hdfs にプッシュしていますが、以下のエラーで失敗します

schema-registry.logs を見ると、次のことがわかります。

件名の topic_out-key が作成されていない理由は何ですか?

0 投票する
1 に答える
2328 参照

go - GoでAvroスキーマを自動的に生成する方法は?

Avro と Schema Registry を Kafka データ パイプラインに統合しようとしています。Goサービスの内部は次のようになります

データを取得 -> データを JSON にエンコード -> Kafka に書き込む

avroスキーマを同じように使いたい

スキーマを生成 -> スキーマ レジストリでスキーマを更新 -> データを取得 -> Avro にエ​​ンコード -> Kafka に書き込む

しかし、いくつかの質問があります:

  1. Go クラスからスキーマを自動的に生成するにはどうすればよいですか?
  2. Schema Registry とのスキーマの互換性を確認するにはどうすればよいですか?

12345678910