我想用python获取Kafka用户组列表，但是我不能。./kafka-consumer-groups.sh -bootstrap-server localhost:9092 -list
浏览 6提问于2018-08-29得票数 3
回答已采纳
我正在使用kafka-python-2.0.1来消费来自kafka代理的数据。到目前为止，我只运行了一个消费者实例。我们每5分钟就会收到2M条记录。我注意到kafka-python不能以更快的速度读取数据以及时消费所有消息。我是kafka-python的新手，不确定如何实现才能更快地读取数据。我应该运行多个使用者吗？
浏览 31提问于2020-11-06得票数 0
3回答
我搜索OpenID-library，它与python3一起工作。我需要成为OpenID提供者和OpenID消费者。tornado.auth仅提供消费者功能。有人使用python3-openid (python-openid的分支)吗？它是如何工作的？
浏览 1提问于2013-01-31得票数 0
1回答
我想从Python应用程序中监控我的Kafka集群中的消费者组(基于Kafka的组，而不是ZK) (我愿意使用Kafka-python库和confluent Kafka客户端中的任何一个)。其目的是根据每个消费者组的滞后推出更多(或删除一些)消费者。
confluent Kafka admin API似乎没有Python选项来实现这一点。Burrow似乎是一种选择。
浏览 2提问于2018-08-13得票数 0
我有python脚本，并且需要使用kafka1 broker集群检索一组从kafka主题读取的消费者的当前消费者组偏移量。这些是原生kafka消费者，将偏移量存储在kafka集群中，而不是zookeeper中。
脚本本身不需要使用任何消息，只需读取其他使用者的当前偏移量。我已经可以利用dpkp/kafka-python客户端做到这一点，但只能通过创建消费者并将其分配给组，然后通过取消分配一些分区来影响使用该组的现有消费者。我需要脚本是完全被动的，不执行任何会中
浏览 1提问于2018-03-12得票数 3
我有一组kafka-python消费者，他们持续并行地使用不同的kafka主题。
我的问题是，如何使用单个python脚本并行启动消费者？管理(启动/停止/监视)这些消费者的最佳方式是什么？
浏览 1提问于2018-03-23得票数 0
1回答
我把kafka和python的消费者一起使用。当消费者运行起来，信息被推送到卡夫卡，然后被消费者阅读时，一切都很好。然而，如果消费者因为任何原因而下降，当它回来的时候，它只读取新的信息，这些信息是在消费者恢复后发布到kafka的。关机-电源之间的消息丢失了，也就是说，用户在恢复后不会读取这些消息。就是我用来创造消费者的东西。
浏览 3提问于2016-01-08得票数 0
回答已采纳
我有一个新的消费者列表(python消费者)。new-consumer --bootstrap-server localhost:9092 --describe --group TheFoundGroupId
如何才能获得与主题相关的所有组(最好是所有的消费者除了将其作为shell命令运行之外，还有其他方法可以从python访问吗？
浏览 9提问于2017-12-21得票数 4
1回答
我想知道是否有可能通过AMQP和RabbitMQ为生产者和消费者使用不同的语言？
例如:生产者使用Java，消费者使用python/php，反之亦然？
浏览 0提问于2012-08-12得票数 3
回答已采纳
1回答
使用多个使用者运行单个队列的Python程序是否有任何方式让多个消费者(例如:5消费者)共享队列中的消息负载，就像每个消费者使用队列中的2条消息一样？
浏览 0提问于2018-11-30得票数 0
回答已采纳
1回答
在尝试时，给出了一个Kafka Consumer和Kafka Producer python代码，我可以在python交互式终端上运行这些代码，并且消费者控制台能够给出输出，但是如果我将它们传递到python消费者consumer = KafkaConsumer('sample') printproducer.send('sample', ke
浏览 1提问于2019-05-06得票数 1
回答已采纳
我正在使用Kafka和python创建一个平台，其中消费者是ML模型，我试图将请求转发到这个ML模型，但大多数时候消费者组正在重新平衡。我有几个问题：
给消费者一个ID来减少再平衡的时间，对吧？，如果消费者逻辑上是分开的，消费不同的话题，那么把他们分成不同的消费者组更好吗？，我如何减少启动系统时的再平衡时间？同样，当我创建消费者时，您是否建议我更改heartbeat_interval_ms和session_timeout_ms？怎么做？
浏览 6提问于2022-10-12得票数 2
1回答
我真的很想使用python协程来简化我的数据消费者，但我发现标准实现并不是很优雅： print('setup')
while Trueprint(data)
pass
有没有办法通过使用for循环来编写消费者print('setup')
for data in yield_iterato
浏览 0提问于2020-08-17得票数 0
我有3个Kafka代理的配置：Topic:logs PartitionCount:8 ReplicationFactor:3 Configs: Topic: logs Partition: 1 Leader: 2 Replicas: 2,0,1 Isr: 0,1,2
浏览 1提问于2015-10-02得票数 0
我正在学习如何在python下使用kafka。p.produce('mytopic', key='hello', value='world')但是，如果将其保存到example.py并运行<
浏览 16提问于2018-01-26得票数 0
回答已采纳
我是卡夫卡世界的新手，我试图在python中为卡夫卡的消费者做以下的事情任何帮助都将不胜感激。
浏览 1提问于2021-04-21得票数 0
回答已采纳
我正在努力收集关于REST服务实现的知识。但是有wadl文件来获取资源路径吗？它需要奥斯钥匙吗？请一步一步地解释如何做到这一点？
浏览 3提问于2013-05-30得票数 0
我在python中遇到了一个关于kafka消费者的问题，这是我的用例，kafka生产者将以实时流的形式每秒发送数据。但kafka消费者需要每30分钟消费一次，采集批量数据。帮我解决这个问题。
浏览 139提问于2019-03-15得票数 1
回答已采纳
1回答
一种是使用python，另一种是使用SQL。展览A (Python)：consumer = Consumer.objects.get(pk=24)
我想找出消费者没有回答的所有调查。因此，我需要根据调查模型的id检查消费者一组选票中的每个question_id(survey.i
浏览 0提问于2018-01-27得票数 1
回答已采纳
1回答
每当在Kafka中创建新主题时，我都试图启动动态消费者，但是动态启动的消费者缺少开始/第一条消息，而是从那里开始消费消息。我正在使用kafka-python模块，并使用更新的KafkaConsumer和KafkaProducer。producer = KafkaProducer(bootstrap_servers='localhost:9092')消费者的代码是",bootstrap_serv
浏览 0提问于2016-02-16得票数 1
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号