From e59e6cf4f6d6e935705c0e1bd6aa751446cfd62b Mon Sep 17 00:00:00 2001
From: Zack Dever <zack.dever@rd.io>
Date: Thu, 13 Aug 2015 12:12:49 -0700
Subject: set default config on consumer class to support subclass config
 changes.

---
 kafka/consumer/kafka.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py
index 11c4221..2141101 100644
--- a/kafka/consumer/kafka.py
+++ b/kafka/consumer/kafka.py
@@ -53,6 +53,7 @@ DEPRECATED_CONFIG_KEYS = {
 
 class KafkaConsumer(object):
     """A simpler kafka consumer"""
+    DEFAULT_CONFIG = deepcopy(DEFAULT_CONSUMER_CONFIG)
 
     def __init__(self, *topics, **configs):
         self.configure(**configs)
@@ -111,8 +112,8 @@ class KafkaConsumer(object):
         """
         configs = self._deprecate_configs(**configs)
         self._config = {}
-        for key in DEFAULT_CONSUMER_CONFIG:
-            self._config[key] = configs.pop(key, DEFAULT_CONSUMER_CONFIG[key])
+        for key in self.DEFAULT_CONFIG:
+            self._config[key] = configs.pop(key, self.DEFAULT_CONFIG[key])
 
         if configs:
             raise KafkaConfigurationError('Unknown configuration key(s): ' +
-- 
cgit v1.2.1