磚

好的解決這個問題。所以我隻有用.option (“kafka.sasl.jaas。配置”,EH_SASL)不工作當我指定選項(“kafka.sasl一樣的細節。用戶名”、“myuser”) .option (“kafka.sasl。密碼”、“mypwd”)

是的@Kaniz開羅。這是很基本的片段。所以你應該試著和再生產,Azure事件中心/卡夫卡,以上片段。

@Kaniz Fatma我有同樣的問題。python導入pyspark.sql %。從pyspark.sql fn功能。類型進口StringType binary_to_string = fn。udf(λx: str (int.from_bytes (x, byteorder = '大')),StringType ()) df = spark.readStream.format (“…