我想将所有分区的偏移量重置为特定值......我看到 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 的内容/格式是什么？
最佳答案
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
关于apache-kafka - 如何在 Kafka Consumer Group 中将偏移量重置为任意值？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/55477753/