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