环境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
一个函数怎么可能需要一个类型类在其模块中没有的参数呢?
1条答案
按热度按时间zazmityj1#
你需要使用一些
org.apache.kafka.common.utils.Time
接口。或者org.apache.kafka.common.utils.SystemTime
或者org.apache.kafka.common.utils.MockTime
.从scala到java的转换使得一些test-utils依赖关系稍微混乱。