我想从卡法卡的数据流中数数单词。我能够做启动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 mytopic
或 spark-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链接
暂无答案!
目前还没有任何答案,快来回答吧!