取消
顯示的結果
而不是尋找
你的意思是:

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

4回複4

Debayan
尊敬的貢獻者三世
尊敬的貢獻者三世

你好,

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

dheeraj2444
新的貢獻者二世

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

Debayan
尊敬的貢獻者三世
尊敬的貢獻者三世

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

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

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

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

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map