测试功能：

@Bean
public Function<KStream<String, String>, KStream<String, String>> process() {

    return processKStream-> processKStream
            .filter((k, v) -> v.getId() > 10;
}

测试装置：

TestTopology testTopology = new TestTopology()

KStream<String, String> processKStream= streamsBuilder.stream("input-topic", Consumed.with(stringSerde, stringSerde));

testTopology.process().apply(processKStream);

topologyTestDriver = new TopologyTestDriver(streamsBuilder.build());

processTaskTestInputTopic = topologyTestDriver.createInputTopic("input-topic", stringSerde.serializer(), stringSerde.serializer());
processTaskTestOutputTopic = topologyTestDriver.createOutputTopic("HERE GOES TOPIC NAME", stringSerde.deserializer(), stringSerde.deserializer());

我的函数"process"不输出主题，因此我没有它的名字。我该如何测试这个函数？
谢谢你的帮助!