关键字参数使用 #python

kafka_python.py

# kafka/consumer/group.py

class KafkaConsumer(six.Iterator):
  DEFAULT_CONFIG = {
    'bootstrap_servers': 'localhost',
    'xxx':'yyy',
  }
  
  def __init__(self, *topics, **configs):
    self.config = copy.copy(self.DEFAULT_CONFIG)
    for key in self.config:
      if key in configs:
        self.config[key] = configs.pop(key)
        
    # Only check for extra config keys in top-level class
    assert not configs, 'Unrecognized configs: %s' % configs