

def __init__(self, *args, **kwargs):
    warnings.warn('The legacy KafkaClient interface has been moved to kafka.SimpleClient - this import will break in a future release', DeprecationWarning)
    super(KafkaClient, self).__init__(*args, **kwargs)

dataset/ETHPy150Open dpkp/kafka-python/kafka/__init__.py KafkaClient.__init__/original