NotLeaderForPartition handling not working

[yannick]

https://github.com/tamediadigital/kafka-d/blob/master/source/kafkad/connection.d#L259
probably because of the mutex

[pszturmaj]

Are you sure it isn't working? I looked at the code and it seems that the mutexes are used only in removeQueue() call, and that works in other cases (like OffsetOutOfRange) so I doubt it's a mutex problem (or I'm missing something...).