腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
如何使用
python
列出Kafka
消费者
组
、
、
我想用
python
获取Kafka用户组列表,但是我不能。./kafka-consumer-groups.sh -bootstrap-server localhost:9092 -list
浏览 6
提问于2018-08-29
得票数 3
回答已采纳
2
回答
kafka-
python
-2.0.1大数据集的性能
、
、
、
我正在使用kafka-
python
-2.0.1来消费来自kafka代理的数据。到目前为止,我只运行了一个
消费者
实例。我们每5分钟就会收到2M条记录。我注意到kafka-
python
不能以更快的速度读取数据以及时消费所有消息。我是kafka-
python
的新手,不确定如何实现才能更快地读取数据。我应该运行多个使用者吗?
浏览 31
提问于2020-11-06
得票数 0
3
回答
Python
3 OpenID-库
、
、
、
我搜索OpenID-library,它与
python
3一起工作。我需要成为OpenID提供者和OpenID
消费者
。tornado.auth仅提供
消费者
功能。有人使用
python
3-openid (
python
-openid的分支)吗?它是如何工作的?
浏览 1
提问于2013-01-31
得票数 0
1
回答
Apache Kafka:对
消费者
组进行程序化监控
、
、
、
、
我想从
Python
应用程序中监控我的Kafka集群中的
消费者
组(基于Kafka的组,而不是ZK) (我愿意使用Kafka-
python
库和confluent Kafka客户端中的任何一个)。其目的是根据每个
消费者
组的滞后推出更多(或删除一些)
消费者
。 confluent Kafka admin API似乎没有
Python
选项来实现这一点。Burrow似乎是一种选择。
浏览 2
提问于2018-08-13
得票数 0
2
回答
使用
python
库检索kafka中的
消费者
组偏移量
、
、
我有
python
脚本,并且需要使用kafka1 broker集群检索一组从kafka主题读取的
消费者
的当前
消费者
组偏移量。这些是原生kafka
消费者
,将偏移量存储在kafka集群中,而不是zookeeper中。 脚本本身不需要使用任何消息,只需读取其他使用者的当前偏移量。我已经可以利用dpkp/kafka-
python
客户端做到这一点,但只能通过创建
消费者
并将其分配给组,然后通过取消分配一些分区来影响使用该组的现有
消费者
。我需要脚本是完全被动的,不执行任何会中
浏览 1
提问于2018-03-12
得票数 3
1
回答
如何让kafka-
python
消费者
并行
、
我有一组kafka-
python
消费者
,他们持续并行地使用不同的kafka主题。 我的问题是,如何使用单个
python
脚本并行启动
消费者
?管理(启动/停止/监视)这些
消费者
的最佳方式是什么?
浏览 1
提问于2018-03-23
得票数 0
1
回答
卡夫卡
消费者
关机后信息丢失状态
、
、
我把kafka和
python
的
消费者
一起使用。当
消费者
运行起来,信息被推送到卡夫卡,然后被
消费者
阅读时,一切都很好。然而,如果
消费者
因为任何原因而下降,当它回来的时候,它只读取新的信息,这些信息是在
消费者
恢复后发布到kafka的。关机-电源之间的消息丢失了,也就是说,用户在恢复后不会读取这些消息。就是我用来创造
消费者
的东西。
浏览 3
提问于2016-01-08
得票数 0
回答已采纳
2
回答
如何看到(新的)
消费者
连接到一个特定的Kafka主题。
、
、
我有一个新的
消费者
列表(
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
回答
带有多个
消费者
的Pika单队列
、
、
、
使用多个使用者运行单个队列的
Python
程序是否有任何方式让多个
消费者
(例如:5
消费者
)共享队列中的消息负载,就像每个
消费者
使用队列中的2条消息一样?
浏览 0
提问于2018-11-30
得票数 0
回答已采纳
1
回答
无法使用
python
使用消息。
、
、
在尝试时,给出了一个Kafka Consumer和Kafka Producer
python
代码,我可以在
python
交互式终端上运行这些代码,并且
消费者
控制台能够给出输出,但是如果我将它们传递到
python
消费者
consumer = KafkaConsumer('sample') printproducer.send('sample', ke
浏览 1
提问于2019-05-06
得票数 1
回答已采纳
1
回答
卡夫卡消费集团花费大量时间进行再平衡。
、
我正在使用Kafka和
python
创建一个平台,其中
消费者
是ML模型,我试图将请求转发到这个ML模型,但大多数时候
消费者
组正在重新平衡。我有几个问题: 给
消费者
一个ID来减少再平衡的时间,对吧?,如果
消费者
逻辑上是分开的,消费不同的话题,那么把他们分成不同的
消费者
组更好吗?,我如何减少启动系统时的再平衡时间?同样,当我创建
消费者
时,您是否建议我更改heartbeat_interval_ms和session_timeout_ms?怎么做?
浏览 6
提问于2022-10-12
得票数 2
1
回答
如何简化
python
协程?
、
、
我真的很想使用
python
协程来简化我的数据
消费者
,但我发现标准实现并不是很优雅: print('setup') while Trueprint(data) pass 有没有办法通过使用for循环来编写
消费者
print('setup') for data in yield_iterato
浏览 0
提问于2020-08-17
得票数 0
2
回答
正常的Kafka偏移滞后是什么?为什么最小值是1(而不是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
1
回答
从文件运行代码的行为与从shell运行代码的行为不同
、
我正在学习如何在
python
下使用kafka。p.produce('mytopic', key='hello', value='world')但是,如果将其保存到example.py并运行<
浏览 16
提问于2018-01-26
得票数 0
回答已采纳
1
回答
卡夫卡蟒蛇-找到新的卡夫卡主题,
消费者
还没有订阅正确的方式是什么?
、
、
、
、
我是卡夫卡世界的新手,我试图在
python
中为卡夫卡的
消费者
做以下的事情任何帮助都将不胜感激。
浏览 1
提问于2021-04-21
得票数 0
回答已采纳
1
回答
获取java.net.SocketException:许可被拒绝:在访问twitter上连接?
我正在努力收集关于REST服务实现的知识。但是有wadl文件来获取资源路径吗?它需要奥斯钥匙吗?请一步一步地解释如何做到这一点?
浏览 3
提问于2013-05-30
得票数 0
1
回答
如何在
python
中每隔30分钟消费一次kafka队列
、
、
我在
python
中遇到了一个关于kafka
消费者
的问题,这是我的用例,kafka生产者将以实时流的形式每秒发送数据。但kafka
消费者
需要每30分钟消费一次,采集批量数据。帮我解决这个问题。
浏览 139
提问于2019-03-15
得票数 1
回答已采纳
1
回答
如何执行Django子查询
、
、
、
一种是使用
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
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Python的Socket知识7:队列、生产者消费者模型
Python使用两个Event对象同步生产者消费者问题
Python网络爬虫3-生产者消费者模型爬取某金融网站数据
服务消费者
消费者投诉:换换回收过分压价,欺瞒消费者
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券