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
