diff options
| author | Lou Marvin Caraig <loumarvincaraig@gmail.com> | 2014-11-26 13:06:21 +0100 |
|---|---|---|
| committer | Lou Marvin Caraig <loumarvincaraig@gmail.com> | 2014-11-26 17:10:03 +0100 |
| commit | a9e77bdaa2490d4c8c343d18f32d7b256c50ddd7 (patch) | |
| tree | 02d7a7fc69748552d2e478b344e6fb8d4cc22a42 /test/testutil.py | |
| parent | 2716d06ea01edc07a52ffb6a645b4b331965b781 (diff) | |
| download | kafka-python-a9e77bdaa2490d4c8c343d18f32d7b256c50ddd7.tar.gz | |
Fixed TestKafkaProducerIntegration
Diffstat (limited to 'test/testutil.py')
| -rw-r--r-- | test/testutil.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/test/testutil.py b/test/testutil.py index fba3869..7661cbc 100644 --- a/test/testutil.py +++ b/test/testutil.py @@ -89,6 +89,10 @@ class KafkaIntegrationTestCase(unittest.TestCase): return self._messages[s].encode('utf-8') + def key(self, k): + return k.encode('utf-8') + + class Timer(object): def __enter__(self): self.start = time.time() |