Hi Apache Kafka Community,

I'd like to start a discussion for KIP-1374: Allow
StreamsBuilder.globalTable to Rekey.

The KIP aims to allow for users to rekey when reading from a topic to
construct a GlobalKTable with the StreamsBuilder.globalTable method. This
would be done by adding overloaded globalTable methods that let a user
supply a KeyValueMapper. This lets StreamsBuilder.globalTable's
customizability get closer to that of StreamsBuilder.addGlobalStore.

KIP: KIP-1374: Allow StreamsBuilder.globalTable to Rekey - Apache Kafka -
Apache Software Foundation
<https://cwiki.apache.org/confluence/spaces/KAFKA/pages/451972636/KIP-1374+Allow+StreamsBuilder.globalTable+to+Rekey>

Jira Issue: [KAFKA-20230] Allow globalTable to provide an optional
KeyValueMapper to materialize an alternative K,V - ASF Jira
<https://issues.apache.org/jira/browse/KAFKA-20230>

Sincerely,
- Hrishi Baskaran

Reply via email to