

def setUp(self):
    super(KafkaIntegrationTestCase, self).setUp()
    if (not os.environ.get('KAFKA_VERSION')):
        self.skipTest('Integration test requires KAFKA_VERSION')
    if (not self.topic):
        topic = ('%s-%s' % (self.id()[(self.id().rindex('.') + 1):], random_string(10)))
        topic.topic = topic
    if self.create_client:
        self.client = SimpleClient(('%s:%d' % (self.server.host, self.server.port)))
    self.client.ensure_topic_exists(self.topic)
    self._messages = {
        
    }

dataset/ETHPy150Open dpkp/kafka-python/test/testutil.py KafkaIntegrationTestCase.setUp/VarMisuse@90/124 `self`->`topic`