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
ob
In http://kafka.apache.org/090/documentation.html#newconsumerconfigs
partition.assignment.strategy should string, not a list of string?
On Fri, Nov 20, 2015 at 5:21 PM, Jun Rao wrote:
> This is the fourth candidate for release of Apache Kafka 0.9.0.0. This a
> major release that includes (1) aut
