這是我用代碼閱讀卡夫卡
inputDF =(火花.readStream .format .option (“kafka.bootstrap(“卡夫卡”)。服務器”,主機).option (“kafka.ssl.endpoint.identification。算法”、“https”) .option (“kafka.sasl。機製”、“普通”).option (“kafka.security。協議”、“SASL_SSL”) .option (“kafka.sasl.jaas。配置”、“kafkashaded.org.apache.kafka.common.security.plain.PlainLoginModule需要用戶名密碼=“{}”=“{}”;”。格式(用戶id、密碼)).option(“訂閱”,主題).option (“kafka.client。id”、“磚”).option (“kafka.group。id”、“new_group2”) .option (“spark.streaming.kafka。maxRatePerPartition”、“5”) .option (“startingOffsets”,“最早”).option (“kafka.session.timeout。女士”,“10000”).option (“minPartitions sc.DefaultParallelism) .load ())
