我已经和kafka消费者和生产者api合作了一段时间，现在我想尝试一下streams api。我在网上看了很多参考资料，但我想不出这一件简单的事。
如何生成只向输出主题发送消息的kstream。
举个例子，他们在github repo上有一个最基本的例子：https://github.com/confluentinc/examples/blob/3.2.x/kafka-streams/src/main/java/io/confluent/examples/streams/wordcountlambdaexample.java 它从一个队列中获取消息，并在对其进行操作后将其发布到另一个队列中。
像这样：

final KStreamBuilder builder = new KStreamBuilder();
final KStream<String, String> textLines = builder.stream();
// do the dirty work...
textLines.to("outputTopic")

但是 builder.stream(); 不存在它至少需要一个输入主题名。
我是不是应该找个Kafka的制作人？如果是这样的话，我就没有幸找到一个明确说明这一点的资源。