我想寫一個數據幀與Avro卡夫卡主題模式使用模式注冊URL鍵和值。to_avro函數不是寫t…

[dheeraj2444]

我想寫一個數據幀與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 ()

[Debayan]

你好,

你能請參考嗎https://github.com/confluentinc/kafka-connect-elasticsearch/issues/59讓我們知道這有幫助。

[dheeraj2444]

這不能幫助解決這個問題。我已經注冊的模式但不知何故to_avro磚的實現是不能選擇正確的一個。我必須定義自己的生產者和通用Avro記錄發送到卡夫卡。to_avro實用方法不能完成。

[Debayan]

@Dheeraj辛格,解決這個問題嗎?如果是的,請您日誌和磚調查實施的案例嗎?

[Kaniz]

嗨@Dheeraj辛格(客戶),我們一直沒有收到你的最後回應@Debayan穆克吉,我檢查,看看他的建議幫助你。

否則,如果你有任何解決方案,請與社區分享,因為它可以幫助別人。

同時,請別忘了點擊“選擇最佳”按鈕時提供的信息幫助解決你的問題。