回答情况：
提问时间：
问题标签：
我使用的是kafka-python版本1.3.3。consumer = KafkaConsumer(....) DO....
浏览 1修改于2018-01-14得票数 0
env: centos，python2.7.9 kafka-python==0.9.3 six==1.9.0 __version__ = pkg_resources.require('kafka-python
浏览 0提问于2017-10-25得票数 1
回答已采纳
我正在尝试用Kafka -Python连接到Kafka-Python，Kafka集群有Kerberos，我们需要构建一些命令来执行一些步骤。有没有其他的连接方式？
浏览 7提问于2016-09-06得票数 9
回答已采纳
我正在使用，我想知道是否有一种方法可以显示所有的主题。./bin/kafka-topics.sh --list --zookeeper localhost:2181
浏览 6修改于2019-05-13得票数 21
回答已采纳
在使用kafka-python包构造KafkaProducer时，我得到了这个错误：
[ERROR] UnrecognizedBrokerVersion: UnrecognizedBrokerVersion
浏览 402修改于2019-11-01得票数 8
回答已采纳
我一直在使用python模块来使用kafka代理。我想使用相同的主题并行地使用'x‘数量的分区。这些文件的内容如下：# typically you would run each on a different server / process / CPU group_id='my-group',
浏览 2修改于2016-05-31得票数 8
回答已采纳
我使用kafka-python版本和1.2.4连接到Cloudera Kafka版本2.0.1 (0.9.9.0)时遇到了问题。和1.2.5。我的python版本是2.6.6。Request.liftedTree2$1(RequestChannel.scala:90)我已经验证了我可以在这台机器上使用kafka-console实用程序进行连接，也可以在另一台机器上使用相同版本的kafka-python
浏览 13修改于2016-07-21得票数 0
我在Python Shell中运行了以下代码：producer = KafkaProducer(bootstrap_servers='localhost:9092')这在Kafka消费者接收消息方面工作得很完美。通过脚本运行它不会产生任何影响。我是不是漏掉了什么明显的东西？future.get(timeo
浏览 7修改于2021-03-05得票数 1
我面临着kafka中的重复数据，所以我想在kafka-python中使用幂等性，但不幸的是它不是它的一部分，我如何才能停止相同分区中的复制数据而不使用幂等性，或者有任何方法导入它或自定义当前的库？
浏览 125提问于2020-12-02得票数 1
我有一组kafka-python消费者，他们持续并行地使用不同的kafka主题。
我的问题是，如何使用单个python脚本并行启动消费者？管理(启动/停止/监视)这些消费者的最佳方式是什么？
浏览 1提问于2018-03-23得票数 0
正如标题中所说，我想在我的主题中获得一些记录，但我找不到使用kafka-python库的解决方案。有谁知道吗？
浏览 88提问于2020-10-07得票数 3
我使用的是kafka-python==1.4.3。
键(可选)-一个与消息相关联的键。可用于确定要向哪个分区发送消息。
浏览 0提问于2019-04-08得票数 0
使用这个，我能够得到partition count per topic，但不能得到replication factor。我能找到的最接近的问题是作为参考。对怎么做有什么想法吗？
浏览 3修改于2022-05-29得票数 0
回答已采纳
我使用kafka-python包将消息发布到kafka confluent云集群。我得到了下面的错误： kafka.errors.NoBrokersAvailable: NoBrokersAvailable confluent kafka手册建议我为C/C++生产者设置以下值；但是，我不能通过kafka-python
浏览 21修改于2019-01-26得票数 2
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号