java - kafka生产者单元测试（java）

Question

用 kafka（java 代码）做我的第一步我想为 kafka 生产者创建一个简单的测试，像这样我可以模拟 zoo keeper（这个实现看起来不错，但我无法访问那里的一些类，特别是 EmbeddedZookeeper和TestUtils）。

有任何想法吗？

Answer 1

您可以使用 Kafka-test 工件：

<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 curator-test 可能会：

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

Answer 2

可能取自 Kafka 源..在这里查看 EmbeddedZk 和这里查看 Utils ..

完整的软件包可在此处获得

看看有没有帮助