我想将所有分区的偏移量重置为特定值......我看到 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 的内容/格式是什么?
apache-kafka ×1