Kakfa embedded cluster rebalance scenario test

[pradeep s <sr...@gmail.com>]

Hi ,
 I would like to add a integration test for kafka rebalance scenario and
make sure retries are working as expected if enough replicas are not there
in my kafka streams application .
Do you have any info on how can i achieve this .
I was checking TestUtils class in org.apache.kafka.test, but could not
figure out a way on how to trigger a rebalance
or NotLeaderForPartitionException scenario using a embedded kafka cluster
Thanks
Pradeep