Avro と Schema Registry を Kafka データ パイプラインに統合しようとしています。Goサービスの内部は次のようになります
データを取得 -> データを JSON にエンコード -> Kafka に書き込む
avroスキーマを同じように使いたい
スキーマを生成 -> スキーマ レジストリでスキーマを更新 -> データを取得 -> Avro にエンコード -> Kafka に書き込む
しかし、いくつかの質問があります:
- Go クラスからスキーマを自動的に生成するにはどうすればよいですか?
- Schema Registry とのスキーマの互換性を確認するにはどうすればよいですか?