gistfile1

@attr('requires-zookeeper')
class TestKafkaTpoicIntegration(BaseIntegrationTest, KafkaIntegrationTestCase):

    @fixture
    def zookeeper(self):
        client = KazooClient()
        client.connect()
        return client

    @fixture
    def kafka_cluster(self):
        return Cluster(self.zookeeper)

    @fixture
    def channel(self):
        return Channel('tests.integration', KafkaTopic(self.kafka_cluster))