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 range assignor which assign
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 Adams
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 rea