Hello, I have a 6 node kafka cluster (0.8.0) where partition reassignment doesn't seem to work on a few partitions. This happens within the same, as well as across other topics. Following is the behavior observed :
1. For a successful reassignment, the kafka-reassign-partitions.sh returns success, I see the controller initiating the reassignment, and the destination brokers start replica fetcher threads. 2. For the unsuccessful reassignment, the tool returns success, but there is nothing in the controller logs nor the destination brokers. Also, for the ones that are successful, some don’t finish replication correctly. I can see that the destination brokers get stuck after a few thousand offsets (checked in JMX), and doesn’t move after that. The controller keeps on waiting for the fetchers to complete, but never gets there. Anyone seen this issue before? Is there a way to reset the state of the controller? or re-elect a new one? Thanks, Raghu