Support Questions
Find answers, ask questions, and share your expertise
Announcements
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

Highlighted

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-1.3.0.0.p0.40/lib/kafka/bin/kafka-consumer-groups.sh --bootstrap-server xxxxxxxxxxxx.devkafka.com:9092 --group testgroup --reset-offsets --by-duration PT1H30M0S --topic Test_Upgrade --export --command-config client.properties 2>/dev/null 

Test_Upgrade,1,615

Test_Upgrade,0,625

 

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

 

user1@xxxxxxxxxxx:~$ /opt/cloudera/parcels/KAFKA-3.0.0-1.3.0.0.p0.40/lib/kafka/bin/kafka-consumer-groups.sh --bootstrap-server xxxxxxxxxxxx.devkafka.com:9092 --group testgroup --reset-offsets --to-datetime 2018-05-31T14:00:00.000 --topic Test_Upgrade --export --command-config client.properties 2>/dev/null 

Test_Upgrade,1,754

Test_Upgrade,0,772

Don't have an account?
Coming from Hortonworks? Activate your account here