The invalid argument exception on a socket connection looks weird. If you
enable debug on kafka.controller.ControllerChannelManager, it will tell you
which broker the newly elected controller is trying to talk to. Then you
will have to make sure that every broker can connect to every other broker.
On Wed, Aug 7, 2013 at 7:40 AM, Jun Rao <[EMAIL PROTECTED]> wrote: