apache-kafka - 如何在 Kafka Consumer Group 中将偏移量重置为任意值？

Question

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

任何人都可以分享这个 csv 文件的内容/格式和它的示例命令吗？

例如:./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 的内容/格式是什么？

Answer 1

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

topicName,partitionNumber,offset
topicName,partitionNumber,offset

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

someTopic1,0,1
someTopic2,1,5

基于 csv 文件重置偏移量的命令是:
./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group gr1 --from-file reset-policy.csv --reset-offsets --execute