Siyuan,
In general 0.9 new consumer API relies on the group coordinator on the
broker side to manage consumer groups, so you would need to upgrade the
brokers first.
However if you are only using the assign() function to assign partitions,
i.e. no subscribe() which will not need the group coordin
Thanks.
I just found the new KafkaConsumer does have two API functions
assignment() and
committed(TopicPartition partition). With these 2 functions, we¹ll be able
to retrieve the timestamp of last offset regardless whether offset storage
is using ZK or offset topic.
Howard
--
Howard Wang
Eng
