Does C++ client support zookeeper based producer load balancing?

Hi, I am starting with kafka. We use version 0.7.2 currently. Does anyone know wether automatic producer load balancing based on zookeeper is supported by the c++ client? Thank you! -- Jan

Does C++ client support zookeeper based producer load balancing?

Hi, I am starting with kafka. We use version 0.7.2 currently. Does anyone know wether automatic producer load balancing based on zookeeper is supported by the c++ client? Thank you! -- Jan

commitOffsets() in multithreaded consumer process

Hi, I have an consumer application where I have a message stream per topic and one thread per stream. I will do a commitOffsets() when a global shared message counter is reaching a limit. I think I need to make sure that no thread is consuming while I call commitOffsets() to ensure that no concu

Re: commitOffsets() in multithreaded consumer process

Jun Rao > The consumer has a config property called consumer.timeout.ms. By setting > the value to a positive integer, a timeout exception is thrown to the > consumer if no message is available for consumption after the specified > timeout value. > > Thanks, > Jun > > &g