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

[Jun MA]

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