kafka 0.11 reset offset for consumer group by --to-datetime

Question

I want to reset the offset of kafka consumer group by timestamp. But when I am using following command:

./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --reset-offsets --to-datetime 2017-11-1907:52:43:00:000 --group <group_name> --topic <topic_name> --execute

I am getting the following error message:

Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers).

how to reset offset according to time

Answer 1

Invoking

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092
--group test-group --reset-offsets --all-topics --to-datetime 2017-08-04T00:00:00.000

can resets offsets to the earliest ones after the given datetime. Datetime format is yyyy-MM-ddTHH:mm:ss.xxx, 2017-08-04T00:00:00.000 for instance.

You could also reset offsets by duration. See an example below:

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 
--group test-group --reset-offsets --all-topics --by-duration PT0H30M0S

--by-duration resets offsets to offset by duration from current timestamp. Format: 'PnDTnHnMnS'.

Answer 2

It's not an error, but just a warning - because you specified --bootstrap-server option then changes will affect only consumers that are implemented using new Java API. If you have consumers that are built using other APIs, then you need to specify --zookeeper option instead.