I think you need to re balance the cluster. something like bin/kafka-reassign-partitions.sh --zookeeper localhost:2181 --topics-to-move-json-file topics-to-move.json --broker-list "5,6" --generate
On Mon, Apr 13, 2015 at 11:22 AM, shadyxu <shad...@gmail.com> wrote: > I added several new brokers to the cluster, there should'v been a rebalance > but it seemed that the producer was not aware of the new brokers. Data kept > being sent to the old brokers and there were no partitions on the new > brokers. > > I configured the old brokers to the producer and did not restart the > producer or add the new brokers to the configuration. > > What may be the problems? >
