eolivelli opened a new pull request #10113: URL: https://github.com/apache/pulsar/pull/10113
### Motivation When you develop a Source you can push KVRecords in order to send records with the KeyValue schema and set properly the KeySchema the ValueSchema and the Key encoding type. On the Sink side you are receiving only Record<KeyValue>, it is better to have a consistent behaviour ### Modifications - set the generic type of KVRecord <K,V> to Record<KeyValue<K,V>> - let Sinks receive instances of KVRecord in case of KeyValue payload and schema ### Verifying this change This change added tests -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
