Hello Yuanjia, Could you share your code example on calling consumer.position()? Is the partition that you are getting the offset from assigned to the consumer?
Guozhang On Wed, Jul 20, 2016 at 11:50 PM, yuanjia8...@163.com <yuanjia8...@163.com> wrote: > Hi, > With kafka-clients-0.10.0.0, I use KafkaConsumer.position() to get > the offset, the process block in ConsumerNetworkClient.awaitMetadataUpdate. > Block until the meadata has been refreshed. > My questions are: > 1. Why the metadata not refresh? > 2. Could it use timeout or throw exception instead of block? > > Thanks. > > > > YuanJia Li > -- -- Guozhang
