Index: core/src/main/scala/kafka/producer/ProducerPool.scala =================================================================== --- core/src/main/scala/kafka/producer/ProducerPool.scala (revision 1352964) +++ core/src/main/scala/kafka/producer/ProducerPool.scala (working copy) @@ -73,7 +73,7 @@ if(syncProducers.size == 0) throw new NoBrokersForPartitionException("No brokers available") } - syncProducers.get(Utils.random.nextInt(syncProducers.size)).get + syncProducers.head._2 } }