自动设置用于测试的Kafka实例
testing.kafka的Python项目详细描述
安装
使用pip:
$ pip install testing.kafka
testing.kafka需要安装zookeeper、kafka和java。
用法
创建kafka和zookeeper实例:
@pytest.fixture def kafka(): zookeeper = testing.zookeeper.ZookeeperServer() kafka = testing.kafka.KafkaServer(zookeeper_url=zookeeper.url()) yield kafka kafka.stop(_signal=signal.SIGKILL) zookeeper.stop(_signal=signal.SIGKILL)