問題タブ [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.
apache-kafka - kafka s3 シンク接続を使用する場合、スキーマ レジストリを使用してスキーマを取得できますか?
私はkafkaトピックを持っています。値はavro形式で、スキーマはスキーマレジストリに保存されています。
ここで、S3 シンクをセットアップします: https://docs.confluent.io/current/connect/connect-storage-cloud/kafka-connect-s3/docs/s3_connector.html#basic-example
ウェブページでは、彼らは使用します
生成された .avro データをリロードしようとすると、スキーマが少し異なることがわかりました。たとえば、ネストされた列挙型は文字列になりました。GenericRecordの代わりにのみ復元できSpecificRecordます。
スキーマ レジストリからスキーマを取得するスキーマ ジェネレータを指定する方法はありますか?
java - JAVA で Avro を使用する Kafka Stream 、 schema.registry.url" にはデフォルト値がありません
Kafka Stream アプリケーションの構成は次のとおりです。
そして、次のエラーが発生しました。
ライン交換してみた
と
しかし、同じエラーで
Stream アプリケーションを準備するときは、この URLの指示に従いました。
なにか提案を？