我正在尝试使用python更新集群配置。
<pre><code>log.retention.hours = 120
log.cleanup.policy = compact
</code></pre>
我正在使用kafka-python == 2.0.1
producer.py
<pre><code>def queue(self, key, value):
self.producer.send(
我正在尝试从python读取Kafka，但收到的消息是None，CLI中没有错误。
我正在使用通过腻子转发到目标主机
我正尝试通过python作为远程生产者将数据发送到Kafka主题。我的脚本未报告任何异常，但Kafka中未显示任
正在尝试从python向kafka消费者发送消息。但是由于<code>ERROR Unknown error when running consumer: org.apache.kafka.common
使用Python-kafka管理客户端，我知道如何创建和删除主题。
但是有什么方法可以检查该主题是否存在
我在经常访问的Scarp网站上使用kafka-python和BeautifulSoup，并与python生产者向kafka经纪人发送消息。
我
我正在从Kafka看书，但消费者挂了电话：
<pre><code>def produce(num, producer, topic_name):
print("hello2")
我将confluent-kafka从1.0.1升级到1.4.2。升级后，如果我执行“ pip install”，则会出现以下错误。
<pre><code>
我正在尝试从本地计算机向Ubuntu vm生成kafka消息。
Telnet commad表示已成功连接到主机。
<pre><code>P
我想通过一个简单的python脚本来产生和使用kafka主题。
如<a href="https://towardsdatascience.com/getting-started-with-a
我有一个主题需要从中使用和处理数据，而我正在使用kafka-python软件包来实现。
我面临着许多与重
我有Django应用，该应用应使用Kafka消息并使用我的处理程序和现有模型进行处理。
我使用<a href="https://kaf
kafka-python客户端如何计算对象到达给定kafka主题的等待时间的秒数。
可以说客户已经订阅了kafka主题，
我正在使用AWS MSK Kafka托管的流服务，突然之间我没有通过消费者收到任何消息。我正在使用kafka-python，
我想检查一个保持时间为100ms的主题后是否为空。
我试图从我的话题中这样消费：
<pre><code> consumer_
我有一个根据订阅主题进行的消费者投票。它消耗每条消息并进行一些处理（在几秒钟内），推送到不
我的Zookeeper和kafka集群都已设置并在本地主机上运行。我有一个生产者和一个使用者从命令提示符处运行
正如标题中所述，我想在自己的主题中获得大量记录，并且找不到使用kafka-python库的解决方案。
有人知
我正在尝试将数据从kafka主题下传到诸如postgres的关系数据库。我不想使用kafka connect或jdbc连接器。我可
