Raise exception in KafkaConsumer on unrecognized kwargs

1 files changed, 4 insertions, 1 deletions

diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index 33563b8..b8b5bde 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -151,7 +151,10 @@ class KafkaConsumer(six.Iterator):
         self.config = copy.copy(self.DEFAULT_CONFIG)
         for key in self.config:
             if key in configs:
-                self.config[key] = configs[key]
+                self.config[key] = configs.pop(key)
+
+        # Only check for extra config keys in top-level class
+        assert not configs, 'Unrecognized configs: %s' % configs
 
         self._client = KafkaClient(**self.config)
         self._subscription = SubscriptionState(self.config['auto_offset_reset'])