如何将KTable输出发布到特定的Kafka主题？

import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.StreamsBuilder;
import org.apache.kafka.streams.StreamsConfig;
import org.apache.kafka.streams.kstream.KTable;
import org.apache.kafka.streams.kstream.Materialized;
import org.apache.kafka.streams.kstream.Produced;
import java.util.Properties;

public class KTableToKafkaTopicExample {
    public static void main(String[] args) {
        // 配置Kafka Streams应用程序的连接信息
        Properties props = new Properties();
        props.put(StreamsConfig.APPLICATION_ID_CONFIG, "ktable-to-kafka-topic");
        props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
        props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());

        // 创建Kafka Streams构建器
        StreamsBuilder builder = new StreamsBuilder();

        // 创建一个KTable
        KTable<String, String> kTable = builder.table("input-topic");

        // 将KTable的输出发送到指定的Kafka主题
        kTable.toStream().to("output-topic", Produced.with(Serdes.String(), Serdes.String()));

        // 创建Kafka Streams实例并启动
        KafkaStreams streams = new KafkaStreams(builder.build(), props);
        streams.start();
    }
}