For Problem 1, you will probably have to either use the low-level API, and/or
do manual partition assignment.
For problem 2, you can simply re-publish the messages to a new topic with more
partitions…or, as in the first problem, just use the low level API. You can
also create more consumer groups (i.e. if you need to add a new consumer of
your topics, but all consumer groups are “full”, just make a new one)
-David
On 4/24/17, 2:01 AM, "揣立武" <chuaili...@gmail.com> wrote:
Hi, all. There are two problems when we use kafka about partitions assigned
to consumers.
Problem 1: Partitions will be reassigned to consumers when consumer online
or offline, then the messages latency become higher.
Problem 2: If we have two partitions, only two consumers can consume
messages。How let more consumers to consume, but expand partitions.
Thanks!
