Kafka NotControllerException: Why It Happens and How to Fix It
Kafka throws NotControllerException (code 41) when an admin request hits a broker that isn't the active controller. Here's the mechanism and the real fix.
Gopi Gorantala
kafka-errors