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 Engineering Big Data and Personalization Washington Post Media 1150 15th St NW, Washington, DC 20071 p. 202-334-9195 Email: howard.w...@washpost.com On 11/30/15, 3:55 PM, "hsy...@gmail.com" <hsy...@gmail.com> wrote: >Is 0.9 new consumer API compatible with 0.8.x.x broker
