import os import random import struct import unittest import kafka.util class UtilTest(unittest.TestCase): def test_relative_unpack(self): pass def test_write_int_string(self): pass def test_read_int_string(self): pass