2回答
我使用的是confluent-Kafka和python。我想将Kafka连接到Hdfs，并将一些特定的数据直接存储在Hdfs中。我找到了confluent HDFS连接器，但我不知道如何将它与我的python脚本连接起来。有什么想法吗？或者有什么替代方法可以将消息直接从Kafka存储到Hdfs？
浏览 1提问于2020-06-08得票数 0
我想写一个python程序，它读取一个文件，并将数据作为一个生产者写入Kafka。Kafka安装在Hadoop集群中，Python将运行在Hadoop集群之外。
可以从外面连接吗？我需要为python安装Kafka库吗？我需要如何安装？
浏览 4提问于2017-12-16得票数 3
回答已采纳
我正在使用kafka-python，并且能够在本地直播。 计算出连接器将处理多个设备。有人能给我推荐一种在python中使用连接器实现它的方法吗？
浏览 28提问于2021-10-07得票数 1
回答已采纳
我正在尝试用Kafka -Python连接到Kafka-Python，Kafka集群有Kerberos，我们需要构建一些命令来执行一些步骤。但是当我尝试连接Kafka-Python时，我遇到了一个问题。-1.3.
浏览 7提问于2016-09-06得票数 9
回答已采纳
当尝试使用通过ssl连接到kafka时Traceback (most recent call last): client = KafkaC
浏览 0提问于2017-07-06得票数 0
我正在尝试通过python将消息发布到kafka主题，但收到一个错误。我可以通过CLI进行连接和发布。希望能得到一些指导。我已经在谷歌上搜索并阅读了文档。谢谢！！value='python_test', key='test') 由此产生的错误： Traceback (most recent call last):
File "kafka_post_test.py\Python37-32\lib\site-packages\ka
浏览 157提问于2019-06-08得票数 1
为Kafka消息队列需要一个适当的python库-客户机端和服务器端示例，以及python中的示例。
将结果反馈给客户。
浏览 10提问于2022-01-24得票数 0
我正在尝试将我的python应用程序连接到在AWS EC2上运行的kafka。我可以通过我用telnet <ec2 ip> 9092检查的终端连接到ec2。我可以通过这个连接，但不能与python应用程序连接。即使我的python应用程序以没有任何错误的kafka ip地址启动，我也不能从我的ec2主题接收从ec2到本地机器的任何数据。当我将我的公共ip地址添加到： advertised.listeners=PLAINTE
浏览 18提问于2020-01-18得票数 0
回答已采纳
我想通过一个简单的python脚本来生成和使用kafka主题。断开连接。('127.0.0.1'，9092)>：1次失败后重新连接回退0.04205048432501722使用"pip install kafka-python“安装kafka-python是否就足够了？kafka
浏览 5提问于2020-09-07得票数 0
回答已采纳
我要做的是运行一个基于wurstmeister/kafka镜像的代理，然后运行另一个使用kafka-python运行简单python脚本的容器。- /var/run/docker.sock:/var/run/docker.sock - zookeeper
build# command to run on container start
CMD ["
浏览 22提问于2021-09-19得票数 2
2回答
我正在尝试构建一个以Kafka为界面的Flask应用程序。我使用了Python连接器、和Docker图像作为Kafka，。/flask-app:/app - kafka
下面是我用来连接到kafka的Python片段。在这里，我使用Kafka容器的别名kafka进行连接，因为Docker将负责将别名映射到它的IP地址。_metrics,
浏览 1提问于2018-11-27得票数 5
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1FROM pythonADD hello.py /RUN pip3 install -r requirements.txtproducer.py的python代码是：
from kafka import Kaf
浏览 1提问于2020-06-05得票数 0
回答已采纳
我看不到太多关于kafka flink连接器python的信息。我知道它是beta version.can，我使用kafkaflink连接器API，使用python.If是的，给我推荐一个这个连接器的程序。我也提到了Apache Flink: Kafka connector in Python streaming API, "Cannot load user class"，.Also，我可以使用python
浏览 31提问于2020-01-23得票数 0
在使用Python3.7.3并带有错误消息SSL: WRONG_VERSION_NUMBER的情况下，使用Python3.6.7中的SSL连接成功连接到Kafka的代码失败。我不会期望在Python3.6中工作的代码在Python3.7中失败。我想知道如何解决这个错误，并使用Python3.7.3通过SSL连接到Kafka。每个脚本运行一个简单的脚本，安装pykafka，然后尝试连接到Kaf
浏览 0提问于2019-11-19得票数 1
回答已采纳
例如，我在源和目的地之间设置了Kafka连接。
我在mysql中有一个表，我想发送给mongodb，我已经将mysql设置为源代码，其中mongodb作为接收器，并且运行良好。现在，当我设置Kafka时，这个链接将转到mongodb，但是我需要的是，在我收到来自mysql源代码的消息之后，我想要执行一个python代码，它下载pdf文件并从中提取文本，所以当我的数据进入mongodb
浏览 1提问于2021-06-22得票数 0
回答已采纳
我将使用pyspark进行流处理，并使用Kafka作为数据源。
我发现Spark Python API不支持Kafka 0.10连接器。我可以在Spark 2.3.0中使用Kafka 0.8连接器吗？
浏览 14提问于2018-03-02得票数 4
在CentOS上使用Python在本地连接到Kafka0.10.0.0时，我遇到了一个非常奇怪的问题。我的连接选项非常简单，而且是默认的： bootstrap_servers=['localhost:9092'], )
当我在Kafka</em
浏览 5提问于2016-08-02得票数 8
在这种情况下，我需要连接到外部kafka并使用数据进行进一步处理。kafka python客户端与Java客户端在实现方式上有根本区别吗？具有相同主机的Python客户端通过TLS连接到代理并消费，但是Kafka控制台使用者或任何基于java的客户端都建立到代理的连接(成功地进行SSL握手)，但由于客户端无法连接和订阅而进一步失败。我知道听众和广告中的听众，但是python能够建立与代理的连接，并消
浏览 2提问于2022-07-12得票数 0
我正试着在AWS上连接卡夫卡。通信是通过TLS完成的。使用Kafka-python==2.0.2，KafkaProducer配置如下：correctlytested 进行了nslookup测试，以检查 java应用程序是否没有工作
浏览 19提问于2022-04-04得票数 0
回答已采纳
我使用kafka-python版本和1.2.4连接到Cloudera Kafka版本2.0.1 (0.9.9.0)时遇到了问题。和1.2.5。我的python版本是2.6.6。下面是命令和异常堆栈跟踪：kafka.network.
浏览 13提问于2016-07-21得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
