如何使用静态记录列表创建KStream以进行单元测试

问题描述 投票:0回答:1

我正在尝试为使用Kafka流的类编写单元测试,如下所示:

KStream stream = streamBuilder.stream(topic)
stream.foreach((key, value) -> {
    // do some data manipulations and validations
});

是否有某种方法可以通过从静态数据创建KStream来为此添加单元测试,像这样获得Strings流:

arrayList.stream();
java spring-boot unit-testing apache-kafka apache-kafka-streams
1个回答
0
投票

使用ToplogyTestDriverTestInputTopic,您可以添加静态记录来使用TestInputTopic.pipeKeyValueList之类的方法测试拓扑。通过这种方式的测试,您可以验证拓扑,而无需运行物理代理的开销。

您可以查看testing Kafka Streams docs了解更多信息。

HTH,帐单

© www.soinside.com 2019 - 2024. All rights reserved.