Just to add when this operation will be going on no new data will be added to original Kafka topic. I am trying to avoid buffering all data to a temporary datastore to sort.
On Thu, 16 Jan 2020, 23:14 Debraj Manna, <subharaj.ma...@gmail.com> wrote: > 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 > >
