我正在尝试为kafka生产者/消费者编写单元测试测试用例,并遇到了一个简单的示例http://grokbase.com/t/kafka/users/13ck94p302/writing-unit-tests-for-kafka-code

在使用此代码时,我发现jar没有Testutils类。我开始研究如何包含此内容,并发现apache不会将Jar中附带Testutils。
我不明白原因。然后找到这个https://issues.apache.org/jira/browse/KAFKA-1308,它要求我运行一些gradle命令。
我很困惑。为什么我需要这样做?有没有更简单的方法来编写此单元测试或包含Testutils?

最佳答案

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.11</artifactId>
    <version>0.8.2.1</version>
    <classifier>test</classifier>
</dependency>

10-07 19:26
查看更多