不同偏移量的水平扩展Kafka消费者
创始人
2025-01-09 12:30:37
0

在Kafka中,当多个消费者订阅同一主题时,每个消费者可能会有不同的偏移量。在水平扩展 Kafka 消费者时,需要考虑各个消费者的偏移量。以下是解决方法的代码示例:

from kafka import KafkaConsumer
from kafka import TopicPartition

# 定义一个列表,其中包含待消费的主题和分区
partitions = [TopicPartition('my_topic', i) for i in range(4)]

# 定义一个字典,将每个消费者ID与其偏移量对应起来
consumer_offsets = {
    'consumer1': {partitions[0]: 10, partitions[1]: 15, partitions[2]: 20},
    'consumer2': {partitions[0]: 5, partitions[1]: 9, partitions[3]: 35}
}

# 定义Kafka消费者
consumer = KafkaConsumer(
    bootstrap_servers=['localhost:9092'],
    group_id='my_group_id',
    auto_offset_reset='earliest',
    enable_auto_commit=False)

# 针对每个消费者,为其分配偏移量
for consumer_id in consumer_offsets:
    for tp in consumer_offsets[consumer_id]:
        consumer.assign([tp])
        consumer.seek(tp, consumer_offsets[consumer_id][tp])

    # 使用消费者进行数据获取
    for message in consumer:
        print(message.value)
        consumer.commit()  # 每获取一条消息,就提交偏移量

在上述代码中,我们首先定义了一个包含所有主题和分区的列表。然后,将每个消费者ID与其偏移量对应起来,存储在一个字典中。在每个消费者启动时,将在字典中查找其偏移量,并将其分配给消费者。然后,使用消费者进行消息获取,并在获取每条消息后提交其

相关内容

热门资讯

必备透视!hhpoker开挂教... 必备透视!hhpoker开挂教程,hhpoker德州作比弊,原来真的是有辅助教程(哔哩哔哩)1、这是...
教你透视!如何判断wpk辅助软... 教你透视!如何判断wpk辅助软件的真假,wpk模拟器是什么,本来一直都是有辅助工具(哔哩哔哩)1、首...
关于透视!wepoker好友房... 关于透视!wepoker好友房开挂,wepoker辅助插件功能,其实是真的有辅助技巧(哔哩哔哩)透视...
开挂透视!wpk模拟器,wpk... 开挂透视!wpk模拟器,wpk模拟器,都是存在有辅助app(哔哩哔哩)1、实时透视辅助更新:用户可以...
专业透视!如何下载德普之星辅助... 专业透视!如何下载德普之星辅助软件,德普之星app安卓版破解版,原来存在有辅助工具(哔哩哔哩)1、游...
必备透视!wpk透视插件,wp... 必备透视!wpk透视插件,wpk软件是正规的吗,真是一直都是有辅助插件(哔哩哔哩)1、免费辅助多个强...
教你透视!wpk控制牌是真的吗... 教你透视!wpk控制牌是真的吗,wpk透视是真的吗,确实是有辅助软件(哔哩哔哩);1、游戏颠覆性的策...
揭露透视!wepoker私人局... 揭露透视!wepoker私人局开挂视频,wepoker私局代打,一贯真的有辅助方法(哔哩哔哩)1、脚...
科普透视!wpk有那种辅助吗,... 科普透视!wpk有那种辅助吗,wpk透视是真的假的,确实是真的有辅助攻略(哔哩哔哩)1、透视辅助软件...
有挂透视!德普之星透视辅助软件... 有挂透视!德普之星透视辅助软件,德普软件,都是一直都是有辅助app(哔哩哔哩)1、每一步都需要思考,...