Support Questions
Find answers, ask questions, and share your expertise
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

How are offsets reset in kafka 0.11

How are offsets reset in kafka 0.11

Expert Contributor

I'm using kafka 0.11. I'm trying to reset the offset of a topic in a consumer group but don't see consistency among the option. How is the offset calculated for different options in kafka-consumer-groups ?


user1@xxxxxxxxxxxx:~$ /opt/cloudera/parcels/KAFKA-3.0.0- --bootstrap-server --group testgroup --reset-offsets --by-duration PT1H30M0S --topic Test_Upgrade --export --command-config 2>/dev/null 




user1@xxxxxxxxxxxx:~$ date Thu May 31 15:30:45 BST 2018


user1@xxxxxxxxxxx:~$ /opt/cloudera/parcels/KAFKA-3.0.0- --bootstrap-server --group testgroup --reset-offsets --to-datetime 2018-05-31T14:00:00.000 --topic Test_Upgrade --export --command-config 2>/dev/null