問題タブ [confluent-platform]
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 は、キー値を汎用レコードとして結合 2 ストリームで例外をスローします
誰かが問題を解決して、キーと値がGenericRecord
. 最初にご覧のとおり、キーと値の AVRO スキーマを使用して 2 つのトピックを作成しています。その後、両方のストリームに参加し、出力トピックで new を作成しますGenericRecord
。これは、プロジェクション スキーマを使用したいわゆるプロジェクション レコードであり、コード スニペットの後に示すように例外が発生しました。
スタックトレース: