Re-key Global K-Table

Is there a way to re-key a Global K-Table? I have a Streams that I wish to join with a Table. However, the only correlation between these two entities is an ID-field which is only present in the record-values themselves. Therefore, I need to change the key for the table records and the stream records.

You will need to pre-process the global table input topic, and use the result topic of the processing step as input for the global table.

Is it possible to do this with application internal topics only? We have a somewhat tedious process in our organization for creating external topics, and we would therefore like to reduce the number of external topics if possible.

Not really. The API is designed such that the global-input topic is a user topic, not an internal topic.

1 Like

This topic was automatically closed 7 days after the last reply. New replies are no longer allowed.