Hi,
I have a topic of records (K1, V1).
This topic is partitioned based on the K1.

I use multiple streams instances to process these records based on that key
so that each instance process certain partitions only.

Now I want to re-key the records in that topic with a format
(K2, V2) and push them into new topic partitioned based on that key (K2).

ie (K1, V1) <=> (K2, V2).

I wanted to know what would be the best way to doing such a transformation.?

What APIs I should look at doing the same?

Thanks
Sachin

Reply via email to