From 2541f6d1360cc36df9d50b970e81e98198c04e7a Mon Sep 17 00:00:00 2001
From: Tim Brooks <tim.brooks@staples.com>
Date: Tue, 28 Apr 2015 11:11:39 -0700
Subject: [PATCH] Synchronize method

---
 .../src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
index d301be4..848eddd 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
@@ -820,7 +820,7 @@ public class KafkaConsumer<K, V> implements Consumer<K, V> {
      * @return The list of partitions
      */
     @Override
-    public List<PartitionInfo> partitionsFor(String topic) {
+    public synchronized List<PartitionInfo> partitionsFor(String topic) {
         Cluster cluster = this.metadata.fetch();
         List<PartitionInfo> parts = cluster.partitionsForTopic(topic);
         if (parts == null) {
-- 
2.3.5