如何更改@KafkaStreamsStateStore kafka Stream Cloud的默认serdes

import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.streams.StreamsConfig;
import org.apache.kafka.streams.kstream.KStream;
import org.apache.kafka.streams.kstream.KStreamBuilder;

import java.util.Properties;

public class KafkaStreamsApp {
    public static void main(String[] args) {
        Properties config = new Properties();
        config.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-streams-app");
        config.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

        // 设置自定义的序列化和反序列化器
        config.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
        config.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());

        KStreamBuilder builder = new KStreamBuilder();
        KStream<String, String> stream = builder.stream("input-topic");

        // 注册自定义的serdes
        stream.to("output-topic", Produced.with(Serdes.String(), Serdes.String()));

        // 构建并启动Kafka Streams应用程序
        KafkaStreams streams = new KafkaStreams(builder, config);
        streams.start();
    }
}