是否总是必须手动为kafka流创建输出主题？

Question

KStream<String, String> kstream = builder.stream("input-topic");
kstream.to("output-topic");

“输入主题”已创建。我没有创建“输出主题”，似乎“Kstream”为我和其他内部主题创建了一个。此外，在“to”函数的javadoc中看到了这一点，指定的主题应该在使用之前手动创建（即，在Kafka Streams应用程序启动之前）

所以我的问题是，我们总是必须手动创建“输出主题”吗？

Answer 1

默认情况下，kafka broker配置为自动。创造话题。enable设置为true，允许尝试从未知主题生成/消费的客户端创建该主题并开始其过程。在Kafka中，最好先明确创建主题，然后再使用它们。这是为了确保不会无意中造成主题溢出，并确保主题设置了正确的分区/复制因子计数。因此，为什么文档状态-应该在使用之前手动创建。

答案是否定的，我们并不总是需要手动创建主题，尤其是在本地环境中工作/四处玩耍时。

注意：如果主题是动态创建的（即在消费者/生产者启动时），则分区/复制因子将设置为服务器中的内容。属性文件。