特牛生活网

streaming读取kafka数据再保存到es7.7.0代码及踩过的坑_spark sql es the host did not accept the connectio-CSDN博客

网友收藏
文章浏览阅读447次。代码import org.apache.kafka.clients.consumer.ConsumerConfigimport org.apache.kafka.common.serialization.StringDeserializerimport org.apache.spark.sql.SparkSessionimport org.apache.spark.streaming.{Seconds, StreamingContext}import org.apache.spark.st_spark sql es the host did not accept the connection within timeout of 60000