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: [email protected] On 11/30/15, 3:55 PM, "[email protected]" <[email protected]> wrote: >Is 0.9 new consumer API compatible with 0.8.x.x broker
