

def msg(self, s):
    if (s not in self._messages):
        self._messages[s] = ('%s-%s-%s' % (s, self.id(), str(uuid.uuid4())))
    return self._messages[s].encode('utf-8')

dataset/ETHPy150Open dpkp/kafka-python/test/testutil.py KafkaIntegrationTestCase.msg/original