kafka-python:我无法运行示例生产者代码

文章/答案/技术大牛

发布

1回答

python、apache-kafka、kafka-python

我已经在Google Cloud VM上创建了Kafka集群首先，我使用cli命令测试了我的代理，以生成message: Producer： $ kafka-console-producer.sh -topic lus_topic --consumer.config /opt/bitnami/kafka/conf/consumer.properties --from-beginning abc 然后，我尝试使用kafka-python生产者</em

浏览 188提问于2021-04-13得票数 0

1回答

用Django运行kafka消费者

python、django、apache-kafka、kafka-consumer-api

我已经在AWS上设置了一个kafka服务器，并且已经有一个Django项目充当生产者，使用kafka-python。我还设置了第二个Django项目作为使用者(kafka-python)，但我正在设法在服务器启动后自动运行使用者，而不必通过API调用触发使用者。到目前为止，我尝试过的一切要么运行使用者，要么阻止服务器启动或运行服务器，阻止使用者。

浏览 10提问于2022-08-24得票数 1

1回答

通过kafka-python将消息发布到融合云集群

python、apache-kafka、kafka-python

我使用kafka-python包将消息发布到kafka confluent云集群。我的代码如下所示： from kafka import KafkaProducer bootstrap_serverssasl_plain_password='[api_secret]') producer.prodcue(topic='file-ingestion',key=b'

浏览 21提问于2019-01-25得票数 2

1回答

如何使用Python从不同服务器连接Kakfa使用者

python-3.x、apache-kafka、kafka-consumer-api、kafka-producer-api、kafka-python

我无法从Kafka服务器接收到任何数据到我的用户服务器。from kafka import KafkaConsumer auto_commit_interval

浏览 1提问于2020-06-11得票数 0

0回答

apache kafka多制作人vs单制作人性能

apache-kafka

我在一台机器上有12个代理的kafka集群，在同一台机器上有一个zookeeper，我使用kafka-python产生消息 producer.send('my_topic', msg) 当我运行我的python代码时，我达到了吞吐量20

浏览 6提问于2017-01-02得票数 1

1回答

如何为一个主题创建或设置分区数量？

python-3.x、apache-kafka、apache-kafka-streams、kafka-producer-api

我使用的是python 3.6.8和kafka-python=2.0.2 有没有办法从python代码中设置主题的分区数量？我的生产者代码如下所示： producer = KafkaProducer(bootstrap_servers=['localhost:9092'],dumps(x).encode('utf-8')) producer.send("RANDOM_NEW_TOPIC", value={'test&

浏览 19提问于2020-10-20得票数 0

回答已采纳

1回答

无法使用python使用消息。

python、apache-kafka、kafka-python

我试图复制中给出的步骤。在尝试时，给出了一个Kafka Consumer和Kafka Producer python代码，我可以在python交互式终端上运行这些代码，并且消费者控制台能够给出输出，但是如果我将它们传递到pythonimport KafkaConsumerfor message in consumer:生产者produce

浏览 1提问于2019-05-06得票数 1

回答已采纳

2回答

Kafka没有与docker中的kaka-python代码交互。

python、docker、apache-kafka

于是我在主机上启动了一个卡夫卡和动物园管理员实例。现在我想通过两个码头工人-生产者和消费者来与它进行互动。生产者码头的代码是：import time producer.send("stupid", str(i))

浏览 5提问于2016-08-12得票数 0

1回答

kafka-python向所有消费者发布

python-2.7、apache-kafka、kafka-python

我使用的是kafka-python==1.4.3。键(可选)-一个与消息相关联的键。可用于确定要向哪个分区发送消息。如果分区为None (并且生产者的分区配置被保留为默认值)，那么具有相同键的消息将被传递到同一个分区(但如果键为None，则随机选择分区)。但如果消息可以发布到所有分区，则无法找到任何线索。

浏览 0提问于2019-04-08得票数 0

1回答

Kafka-Python，生产者发送记录但消费者未收到

docker、kafka-consumer-api、kafka-producer-api、kafka-python

我在使用kafka编写我的python代码时遇到了问题。我使用的是python 2.7.5和kafka-python包。我想通过一个卡夫卡主题发送csv的(300000行，每行20个字段)。在此之前，我将每一行序列化为一个json文件，在此之前，一切正常。我的生产者发送每一行文件，然后关闭。但另一方面，我的消费者不消费任何东西。就kafka而言，我只有一个主题和一个分区。我的k

浏览 49提问于2021-01-21得票数 0

2回答

无法向Kafka Python中的Topic发送消息

python、apache-kafka、kafka-python

我有一个生产者代码，在那里我发送消息给卡夫卡。没有任何失败或错误消息，代码可以执行，但不会发送消息。kafka-python==2.0.1下面是我的代码，import loggingproducer.send(

浏览 3提问于2020-06-16得票数 0

1回答

如何使用kafka-python发送自定义负载？(同一WIFI网络下的两台ubuntu机器)

python、apache-kafka

如何使用kafka-python发送自定义负载？我有“两台ubuntu机器”，而且都在同一个WIFI网络下(一个地址是172.20.10.2，另一个地址是172.20.10.7)，我可以使用深流test4 python脚本通过kafka成功地传输检测到的包围盒信息因此，我尝试了一些kafka-python scrpit。对于生产者： from time import sleepfrom kafka import KafkaProducer

浏览 11提问于2021-07-29得票数 0

1回答

使用Kafka-python处理生产者和消费者

python、apache-kafka、apache-zookeeper、broker、kafka-python

首先，我想说，我是卡夫卡的新手，也是堆积如山，所以我很抱歉，如果我没有以正确的方式问这个问题。我正在尝试使用kafka-python实现生产者-消费者。但它不能正常工作 p

浏览 1提问于2019-08-27得票数 2

回答已采纳

1回答

卡夫卡消费者没有获取所有信息

python、apache-kafka、producer-consumer

每当在Kafka中创建新主题时，我都试图启动动态消费者，但是动态启动的消费者缺少开始/第一条消息，而是从那里开始消费消息。我正在使用kafka-python模块，并使用更新的KafkaConsumer和KafkaProducer。制片代码是record_metadata = producer.send(topic, data)consu

浏览 0提问于2016-02-16得票数 1

回答已采纳

3回答

卡夫卡生产者配置重试策略

python、apache-kafka、kafka-producer-api、rsyslog、confluent-platform

需要更改Kafka配置的哪些参数，以便生产者应该: 1)在n次间隔后对同一消息重试n次2)，以防代理关闭。我需要处理一个与此相关的情况：

浏览 5提问于2017-03-02得票数 3

1回答

来自python NoBrokersAvailable的Kafka Consumer

python、apache-kafka

我正在使用docker通过以下命令运行一个kafka生产者advertised.port=9092listeners=PLAINTEXT://xxx.xx.x.xkafka-console-consumer.sh --topic USE

浏览 3提问于2019-03-20得票数 2

1回答

Python Kafka SyntaxError，同时运行生产者或消费者

python、apache-kafka、apache-zookeeper

我是kafka的新手，正在尝试使用链接创建一个简单的hello world应用程序。我运行了zookeeper，然后运行了kafka-server-start命令，但是当我执行生产者时，我得到了以下错误 Filekafka-python版本修改为1.4.3，似乎什么都不起作用。producer.send('sample', key=b'message-two'

浏览 6提问于2019-03-07得票数 1

1回答

无法使用Python在Kafka中设置消费者组

apache-kafka

我是Kafka的新手，我已经尝试过Kafka-Python包。consumer.subscribe([queue_name]) 为了进行比较，我还尝试了confluent-kafka-python包，其中我有以下消费者代码</

浏览 1提问于2019-03-19得票数 0

1回答

Python生产者可以通过shell发送，但不能通过.py发送。

python、python-3.x、apache-kafka、kafka-python

我有一个运行并经过测试的Kafka集群，并且正在尝试使用Python脚本向代理发送消息。我正在为消费者和生产者使用kafka-python库。当我使用Python3 shell时，我可以看到使用Kafka工具2.0.4出现在主题中的消息--我在python代码中尝试过各种循环和语句，但似乎没有什么能使它“运行”完成。当我将与上面相同的代码放入python .py文件并使用Python3执行时，它就完成了，但是没有数据

浏览 0提问于2019-04-05得票数 1

回答已采纳

2回答

如何与位于minikube的制片人联系

python、apache-kafka、minikube

所以，我没主意了。我会使用位于minikube上的生产者(用python编写，使用kafka-python库)在我的localpc中访问kafka集群。生产者代码是：try: producer = KafkaProducer(bootstrap_servers=['local-ipf"record_metadata.offset {record_metadata.o

浏览 45提问于2019-08-22得票数 0

点击加载更多