def setUp(self):
    self.topic = 'test_topic'
    self.zk = ZookeeperService(self.test_context, num_nodes=1)
    self.zk.start()
    self.producer_throughput = 10000
    self.num_producers = 1
    self.num_consumers = 1
    self.messages_per_producer = 100
def setUp(self):
    self.topic = 'test_topic'
    self.zk = ZookeeperService(self.test_context, num_nodes=1)
    self.zk.start()
    self.producer_throughput = 10000
    self.num_producers = 1
    self.num_consumers = 1
    self.messages_per_producer = 100