导入 Kafka MockAdminClient 以使用 Maven 对我的 Kafka 应用程序进行单元测试

Hun*_*orn 2 java apache-kafka

我想使用MockAdminClient我的 Kafka 应用程序进行单元测试。如何MockAdminClient使用 进行导入maven

https://github.com/apache/kafka/blob/2.3.0/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java

更新:

我的kafka-client相关的pom.xml

<dependency>
   <groupId>org.apache.kafka</groupId>
   <artifactId>kafka-clients</artifactId>
    <version>${kafka.version}</version>
</dependency>
Run Code Online (Sandbox Code Playgroud)

通过引用maven的测试,我发现了这样的 How can I reference unit test classes of a maven dependency in my java project?

cri*_*007 5

您需要拉出测试分类器,然后添加测试范围以使其仅适用于您的单元测试

<dependency>
   <groupId>org.apache.kafka</groupId>
   <artifactId>kafka-clients</artifactId>
   <version>${kafka.version}</version>
   <classifier>test</classifier>
   <scope>test</scope>
</dependency>
Run Code Online (Sandbox Code Playgroud)