我正在尝试为使用Kafka流的类编写单元测试,如下所示:
KStream stream = streamBuilder.stream(topic)
stream.foreach((key, value) -> {
// do some data manipulations and validations
});
是否有某种方法可以通过从静态数据创建KStream来为此添加单元测试,像这样获得Strings流:
arrayList.stream();
使用ToplogyTestDriver和TestInputTopic,您可以添加静态记录来使用TestInputTopic.pipeKeyValueList之类的方法测试拓扑。通过这种方式的测试,您可以验证拓扑,而无需运行物理代理的开销。
您可以查看testing Kafka Streams docs了解更多信息。
HTH,帐单