Hi I have a Kafka topic with X partitions. Each message has a timestamp, ts. Can someone suggest me some way of sorting all the messages (based on ts) across all partitions and putting it in a new topic with Y partitions (Y < X ) using Kafka java client?
Thanks