搜索 - 腾讯云开发者社区-腾讯云

文章/答案/技术大牛

发布

来自专栏悠扬前奏的博客
Kafka多分区下二分法查找指定时间戳的offset
tp2_start_offset, tp2_nos = tp2_nos, int((tp2_nos + tp2_end_offset) / 2) print("Partition tp2_nos, tp2_end_offset = int((tp2_nos + tp2_start_offset) / 2), tp2_nos print("Partition , tp0_nos, tp0_end_offset) print('Partition-1: ', tp1_start_offset, tp1_nos, tp1_end_offset) print('Partition
1K10发布于 2021-11-24
来自专栏Flink实战剖析
Flink 实现Locality 模式调度
生成的配置放在ExecutionConfig中的GlobalParameters中，实际效果图：代表着下标为0的task消费partition-2,同时部署在rack-a中的机器上，下标为1的task
35330编辑于 2022-04-18
来自专栏架构之家
Redis、Kafka 和 Pulsar 消息队列对比
": { "groupA": { "partition-0": 0, "partition-1": 123, "partition }, "groupB": { "partition-0": 85, "partition-1": 9991, "partition
1.4K20编辑于 2022-07-12
来自专栏【腾讯云开发者】
从演进式角度看消息队列
topic-foo": { "groupA": { "partition-0": 0, "partition-1": 123, "partition }, "groupB": { "partition-0": 85, "partition-1": 9991, "partition
1.1K30发布于 2021-04-13