我想寫一個數據幀與Avro卡夫卡主題模式使用模式注冊URL鍵和值。to_avro函數不寫主題和拋出異常代碼40403。有一個替代的方法嗎?
錯誤信息:
引起的:RestClientException:模式未找到;錯誤代碼:40403
這就是我使用to_avro:
val kafkaDf = df。選擇(to_avro(“價值”美元,點燃(“topicName-value”), schemaRegistry)。as(“價值”))kafkaDf .write .format .option (“kafka.bootstrap(“卡夫卡”)。服務器”,bootstrapServer) .option(“主題”,topicName) .option (“schema.registry。url”, schemaRegistry) .option (AbstractKafkaAvroSerDeConfig。SCHEMA_REGISTRY_URL_CONFIG schemaRegistry) .save ()
這不能幫助解決這個問題。我已經注冊的模式但不知何故to_avro磚的實現是不能選擇正確的一個。我必須定義自己的生產者和通用Avro記錄發送到卡夫卡。to_avro實用方法不能完成。