Thanks Guozhang.
Yuanjia Li
From: Guozhang Wang
Date: 2016-07-26 07:06
To: users@kafka.apache.org
Subject: Re: Re: KafkaConsumer position block
Hi Yuanjia,
If the consumer has just been created and there is no metadata in it yet,
seeking to the latest offset would require at least two round
INFO [delete-topics-thread-61], Stopped
> (kafka.controller.TopicDeletionManager$DeleteTopicsThread)
>
>
>
> YuanJia Li
>
> From: Guozhang Wang
> Date: 2016-07-22 02:07
> To: users@kafka.apache.org
> Subject: Re: KafkaConsumer position block
> Hello Yuanjia,
&g
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
[2016-07-21 18:25:27,809] INFO [delete-topics-thread-61], Stopped
(kafka.controller.TopicDeletionManager$DeleteTopicsThread)
YuanJia Li
From: Guozhang Wang
Date: 2016-07-22 02:07
To: users@kafka.apache.org
Subject: Re: KafkaConsume
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
wrote:
> Hi,
> With kafka-clients-0.10.0.0, I use KafkaConsumer.
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 ex
