如何在 Kafka Consumer Group 中将偏移量重置为任意值? [英] How to reset offsets to arbitrary value in Kafka Consumer Group?

问题描述

我想将所有分区的偏移量重置为特定值......我看到 kafka-consumer-groups.sh 提供了 --from-file 将偏移量重置为 CSV 文件中定义的值的选项

I want to reset offsets of all partitions to specific values .... I see kafka-consumer-groups.sh provides option of --from-file Reset offsets to values defined in CSV file

谁能分享这个 csv 文件的内容/格式和它的示例命令?

Can anyone please share contents/format of this csv file and example command for it ?

例如:./kafka_2.12-2.1.1/bin/kafka-consumer-groups.sh --bootstrap-server ${KAFKA_BROKER} --group ${GROUP_NAME} --topic ${TOPIC} --reset-offsets--from-file offsets.csv --execute

offsets.csv 的内容/格式是什么?

Whats contents/format of offsets.csv ?

推荐答案

Csv文件格式为(每一行包含一个分区的信息):

Csv file format is (Each line contains information about one partition):

topicName,partitionNumber,offset
topicName,partitionNumber,offset

示例 csv 内容 (reset-policy.csv).

Sample csv content (reset-policy.csv).

someTopic1,0,1
someTopic2,1,5

基于csv文件重置偏移量的命令是:

Command to reset offset based on csv file is:

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group gr1 --from-file reset-policy.csv --reset-offsets --execute

这篇关于如何在 Kafka Consumer Group 中将偏移量重置为任意值?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！