当我运行我的python脚本时,我得到一个关于from kafka import KafkaProducer的错误。/kafka/__init__.py", line 23, in <module> File "/Library/Frameworks/Python.framework/Versions/3.8
"D:/Python/consumer.py", line 1, in <module> File "D:\Python\venvFile "D:\Python\venv\lib\site-packages\kafka\producer\__init__.py", line 4, in <module>
我正在尝试使用apache的WriteToKafka类(python )编写一个流到Kafka主题。但是,它无休止地运行脚本(没有错误),并且不向主题写入流。我必须取消运行,它不会停止,不会产生错误。下面可以找到一个很小的例子来重现问题import os
from apache_beam.options.pipeline_optionsimport PipelineOptions
from
我有下面的python脚本,它从twitter中提取推特并将其发送到kafka主题。这个脚本运行得很完美,但是当我试图在一个码头容器中运行它时,它无法导入kafka库。File "/usr/local/lib/python3.7/site-packages/kafka/__init__.py", line 23, in <module>
from kafka.producerim
我正在使用Python3.6.8在Ambari上运行Spark版本2.3.0.2.6.5.1175-1。StateStoreCoordinatorRef:在线程"Thread-10“java.lang.NoClassDefFoundError中注册的StateStoreCoordinator端点异常:kafkaoccurred while calling o93.createDirectStreamWithMessageHandler火花-sql 0-10_2.11-2.3.0.jar火花流-kafkab