Kafka生产者单元测试(java)

4smxwvx5 于 2021-06-07 发布在 Kafka

关注(0)|答案(2)|浏览(474)

在使用kafka（java代码）进行我的第一步时，我想为kafka producer创建一个简单的测试，在这里我可以模拟zoo keeper（这个实现看起来不错，但是我无法访问其中的一些类，特别是embeddedzookeper和testutils）。
有什么想法吗？

Java apache-kafka apache-zookeeper unit-testing

来源：https://stackoverflow.com/questions/19243981/kafka-producer-unit-test-java

2条答案

按热度按时间

zphenhs41#

您可以使用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 curator测试可能会执行以下操作：

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

赞(0）回复(0）举报 2021-06-07

ercv8c1e2#

可能是Kafka的资料。。请检查此处的embeddedzk和此处的utils。。
这里提供全套服务
看看有没有用

赞(0）回复(0）举报 2021-06-07