Reset Kafka Consumer Group Offset
kafka-consumer-groups \
--bootstrap-server ${kafka_hosts} \
--group ${consumer_group} \
--topic ${topic} \
--reset-offsets \
--to-latest \
--execute
Available reset options:
--shift-by <integer> (note: can be negative)
--to-current
--to-latest
--to-offset <offset_integer>
--to-datetime <datetime_string>
--by-duration <duration_string>
Reset Kafka Consumer Group Offset for a Specific Partition
kafka-consumer-groups \
--bootstrap-server ${kafka_hosts} \
--group ${consumer_group} \
--topic ${topic}:${partition_number} \
--reset-offsets \
--to-latest \
--execute