kafka生产者单元测试(java)

Question

用kafka(java代码)做我的第一步我想为kafka生成器创建一个简单的测试,像这样我可以模拟动物园饲养员(这个实现看起来不错,但我无法到达那里的一些类,特别是EmbeddedZookeeper和TestUtils).

有任何想法吗？

Answer 1

您可以使用Kafka测试工件:

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.9.2</artifactId>
    <version>0.8.0</version>
    <classifier>test</classifier>
    <scope>test</scope>
</dependency>

如果你需要为zookeeper单独模拟,Apache策展人测试可能会:

<dependency>
    <groupId>org.apache.curator</groupId>
    <version>2.3.2-SNAPSHOT</version>
    <artifactId>curator-test</artifactId>
    <scope>test</scope>
</dependency>