I have a topic with 5 partitions that I want to repartition to a topic having a single partition.
Since the source topic contains a lot of historical data I want to make sure that the timestamps of the records in the target topic do not differ too much (below a certain threshold).
I’m looking for a solution that satisfies the following conditions:
- Timestamps in the target topic do not differ too much
- Records shall be written immediately to the topic if the above condition is met
A solution using kafka streams is preffered….