ImAbhishekTomar -磚

ImAbhishekTomar · 10-07-2022

我麵臨一個錯誤當試圖使用火花卡夫卡流寫入數據。#提取source_stream_df =(火花。readStream .format .option (“spark.cosmos (“cosmos.oltp.changeFeed”)。容器”,PARM_CONTAINER_NAME) .option (“spark.cosmos.read.inferSchema.en…

ImAbhishekTomar · 04-21-2022

嗨,使用下麵的宇宙DB查詢可以實現預期的輸出,但是我怎麼能做同樣的磚的火花SQL。COSMOSDB查詢:選擇c.ReportId c.ReportName,我。價格,從c p作為提供者加入我在i.pr in_network加入p…

ImAbhishekTomar · 02-22-2023

有沒有人找到解決方案,我也使用類似的混亂和勞和數據攝入大量時間…。?

ImAbhishekTomar · 10-07-2022

有其他方法來檢查我的磚集群和卡夫卡的經紀人之間的連接?

ImAbhishekTomar · 10-07-2022

@Sivaprasad——當我telnet代理和港口磚然後顯示connected.Thanks,阿布

磚

用戶數據

用戶活動

kafkashaded.org.apache.kafka.common.errors.TimeoutException: topic-downstream-data-nonprod 60000毫秒後沒有出現在元數據。

試圖摧毀我的Json使用CosmosDB火花連接器——Azure磚

Re:需要幫助將龐大的數據插入到宇宙db使用磚從azure湖數據存儲

再保險:kafkashaded.org.apache.kafka.common.errors.TimeoutException: topic-downstream-data-nonprod 60000毫秒後沒有出現在元數據。

再保險:kafkashaded.org.apache.kafka.common.errors.TimeoutException: topic-downstream-data-nonprod 60000毫秒後沒有出現在元數據。