kafka.utils.time不存在

kmbjn2e3  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(424)

环境pom.xml

<dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka_2.11</artifactId>
        <version>0.10.1.0</version>
        <classifier>test</classifier>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>0.10.1.0</version>
        <classifier>test</classifier>
        <scope>test</scope>
    </dependency>

申请代码:

import kafka.utils.MockTime;

"""
 Time mock = (Time) new MockTime();
 kafka = TestUtils.createServer(kafkaConfig, mock);
"""

问题是:
testutils中的createserver函数需要一个time类作为第二个参数,但是utils中没有time类
这意味着

import kafka.utils.Time

将失败
如果我使用org.apache.kafka.common.utils.time,
testutils.createserver抱怨

The method createServer(KafkaConfig, Time) from the type TestUtils refers to the missing type Time

一个函数怎么可能需要一个类型类在其模块中没有的参数呢?

zazmityj

zazmityj1#

你需要使用一些 org.apache.kafka.common.utils.Time 接口。或者 org.apache.kafka.common.utils.SystemTime 或者 org.apache.kafka.common.utils.MockTime .
从scala到java的转换使得一些test-utils依赖关系稍微混乱。

相关问题