def kafka_consumer(self, **configs):
        brokers = '%s:%d' % (self.server.host, self.server.port)
        consumer = KafkaConsumer(self.topic,
                                 bootstrap_servers=brokers,
                                 **configs)
        return consumer
dataset/ETHPy150Open dpkp/kafka-python/test/test_consumer_integration.py/TestConsumerIntegration.kafka_consumer/original