We have recently setup a new kafka (0.7.1) cluster with two brokers. Each topic has 2 partitions per server. We have a two processes that that write to the cluster using the class: kafka.javaapi.producer.Producer.Producer.
The problem is that the first process only writes to the first broker. The second process (using the exact same code to perform the write) successfully writes to both brokers. How can I identify the cause of the imbalance in the first process? How does the Producer decide which broker is the recipient of each message? Thanks! --Tom
