You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by "hsy541@gmail.com" <hs...@gmail.com> on 2015/11/30 20:01:28 UTC

partitionsFor method doesn't return latest partition metadata

Hi guys,

I want to use partitionsFor method of new consumer API periodically to get
the monitor partition metadata change, It seems it only issue remote call
to the server for the first time. If I add partitions after that,
partitionsFor will return stale value. Is there a way to reuse consumer
object to refresh the metadata change. Thanks!

regards,
Siyuan