私はkafkaトピックを持っています。値はavro形式で、スキーマはスキーマレジストリに保存されています。
ここで、S3 シンクをセットアップします: https://docs.confluent.io/current/connect/connect-storage-cloud/kafka-connect-s3/docs/s3_connector.html#basic-example
ウェブページでは、彼らは使用します
schema.generator.class=io.confluent.connect.storage.hive.schema.DefaultSchemaGenerator
生成された .avro データをリロードしようとすると、スキーマが少し異なることがわかりました。たとえば、ネストされた列挙型は文字列になりました。GenericRecordの代わりにのみ復元できSpecificRecordます。
スキーマ レジストリからスキーマを取得するスキーマ ジェネレータを指定する方法はありますか?