Reply
Highlighted
Contributor
Posts: 78
Registered: ‎10-04-2017

How are offsets reset in kafka 0.11

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

Announcements