使用spark3.0和python语言从kafka流式传输数据

wbrvyc0a  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(199)

我想从卡法卡的数据流中数数单词。我能够做启动zookeeper,Kafka服务器,创建主题,生产者和消费者即我能够发送文本从生产者和接受消费者。但我不能访问python代码。 zookeeper-server-start.sh $KAFKA_HOME/config/zookeeper.properties kafka-server-start.sh $KAFKA_HOME/config/server.properties kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytopic kafka-console-producer.sh --bootstrap-server localhost:9092 --topic mytopic kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytopic --from-beginning 运行python代码 spark-submit StreamDatafromKafka.py localhost:9092 mytopicspark-submit StreamDatafromKafka.py localhost:9092 mytopic —-packages org.apache.spark:spark-streaming-kafka-0–8_2.11:2.0.0 错误:pyspark.sql.utils.analysisexception:未能找到数据源:kafka。
github链接

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题