Re: Consumer Balancing multi topic, single partition

Thanks, works well For someone searching for this.. Example: props.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG, "org.apache.kafka.clients.consumer.RoundRobinAssignor"); > On 12 Jan 2017, at 11:37 PM, tao xiao wrote: > > The default partition assignor is

Re: Consumer Balancing multi topic, single partition

The default partition assignor is range assignor which assigns works on a per-topic basis. If you topics with one partition only they will be assigned to the same consumer. You can change the assignor to org.apache.kafka.clients.consumer.RoundRobinAssignor On Thu, 12 Jan 2017 at 22:33 Tobias

Consumer Balancing multi topic, single partition

Hi We have a scenario where we have a lot of single partition topics for ordering purposes. We then want to use multiple consumer processes listening to many topics. During testing it seems like one consumer process will always end up with all topics/partitions assigned to it and there is no