如何使用Kafka Stream API向topic的多个分区写入数据

import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.StreamsBuilder;
import org.apache.kafka.streams.StreamsConfig;
import org.apache.kafka.streams.kstream.KStream;
import java.util.Properties;

public class KafkaStreamExample {
    public static void main(String[] args) {
        // 配置Kafka Streams应用程序的参数
        Properties props = new Properties();
        props.put(StreamsConfig.APPLICATION_ID_CONFIG, "kafka-stream-example");
        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();

        // 定义输入和输出的topic
        String inputTopic = "input-topic";
        String outputTopic = "output-topic";

        // 从输入topic读取数据流
        KStream<String, String> inputStream = builder.stream(inputTopic);

        // 对数据流进行处理，这里示例将数据转换为大写并写入输出topic
        inputStream.mapValues(value -> value.toUpperCase()).to(outputTopic);

        // 创建Kafka Streams应用程序
        KafkaStreams streams = new KafkaStreams(builder.build(), props);

        // 启动应用程序
        streams.start();

        // 程序运行一段时间后关闭
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        streams.close();
    }
}