From d53a8e2e786c78e22c5f3c712e5e5e41251335e4 Mon Sep 17 00:00:00 2001 From: Dragos Dena Date: Fri, 13 Dec 2013 16:34:39 +0200 Subject: [PATCH] KAFKA-1183 DefaultEventHandler causes unbalanced distribution of messages across partitions --- core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala b/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala index d8ac915..72de05b 100644 --- a/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala +++ b/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala @@ -59,6 +59,7 @@ class DefaultEventHandler[K,V](config: ProducerConfig, var outstandingProduceRequests = serializedData var remainingRetries = config.messageSendMaxRetries + 1 val correlationIdStart = correlationId.get() + sendPartitionPerTopicCache.clear() debug("Handling %d events".format(events.size)) while (remainingRetries > 0 && outstandingProduceRequests.size > 0) { topicMetadataToRefresh ++= outstandingProduceRequests.map(_.topic) -- 1.8.3.4 (Apple Git-47)