将消息在Kafka分区之间排序，并将其放入另一个Kafka主题中。

要将消息在Kafka分区之间排序并将其放入另一个Kafka主题中，可以使用Kafka Streams库来实现。下面是一个使用Java编写的示例代码：

import org.apache.kafka.streams.*;
import org.apache.kafka.streams.kstream.KStream;

import java.util.Properties;

public class KafkaMessageSorter {
    public static void main(String[] args) {
        // 设置Kafka Streams的配置
        Properties props = new Properties();
        props.put(StreamsConfig.APPLICATION_ID_CONFIG, "message-sorter");
        props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

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

        // 从输入主题中读取消息流
        KStream<String, String> messageStream = builder.stream("input-topic");

        // 对消息流进行排序
        KStream<String, String> sortedMessageStream = messageStream
                .selectKey((key, value) -> value) // 将消息值作为新的键
                .groupByKey() // 按键进行分组
                .reduce((value1, value2) -> value1 + ", " + value2) // 将相同键的值合并为一个字符串
                .toStream(); // 将结果转换为KStream

        // 将排序后的消息流发送到输出主题
        sortedMessageStream.to("output-topic");

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

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

        // 关闭应用程序时优雅地关闭流
        Runtime.getRuntime().addShutdownHook(new Thread(streams::close));
    }
}

在上面的示例代码中，我们首先设置了Kafka Streams的配置，包括应用程序ID和Kafka服务器的地址。然后，我们创建了一个Kafka Streams的构建器，并从输入主题中读取消息流。接下来，我们对消息流进行排序，将消息值作为新的键，然后按键进行分组，并将相同键的值合并为一个字符串。最后，我们将排序后的消息流发送到输出主题中。

要运行此示例代码，您需要在本地安装Kafka并创建相应的输入和输出主题。您还需要添加所需的Kafka Streams依赖项到您的项目中。

请注意，上面的示例代码仅为演示目的，并没有考虑处理重复消息、故障恢复以及其他生产环境中的一些重要细节。在实际使用中，您可能需要根据具体需求对代码进行适当的修改和优化。