You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Jun MA <mj...@gmail.com> on 2018/01/25 05:13:48 UTC

How to set partition.assignment.strategy at run time?

Hi all,

I have a custom PartitionAssignor class that would need a parameter to construct the class. So instead of specify partition.assignment.strategy with the class name in the consumer properties, how could I do it at runtime? I’m using kafka 0.9 java client.

Thanks,
Jun