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 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 Adamson wrote:
>
> 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 real distribution
> going on.
>
> Does the assignment process take into account the total number of
> partitions assigned to each consumer process or does it only
> check assignment per topic?
>
> Regards
> Toby