Kafka POM 依赖问题 - ClassNotFoundException: org.apache.kafka.test.TestCondition

Question

我在集成测试中看到 - java.lang.NoClassDefFoundError: org/apache/kafka/test/TestCondition。我认为这与存储库导入kafka 相关包的方式有关。我正在添加使用 scope 和 classifiers 的 pom 依赖项。

你能帮忙解决这个问题吗？

     <kafka-clients.version>0.10.2.1</kafka-clients.version>

     <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-streams</artifactId>
        <version>${kafka-clients.version}</version>
        <classifier>test</classifier>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-streams</artifactId>
        <version>${kafka-clients.version}</version>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>${kafka-clients.version}</version>
    </dependency>

Answer 1

    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>${kafka-clients.version}</version>
        <classifier>test</classifier>
    </dependency>

TestCondition 在 kafka-clients-version-test.jar 所以将分类器测试添加到'kafka-clients' artifactId