eolivelli commented on issue #9899: URL: https://github.com/apache/pulsar/issues/9899#issuecomment-800061449
Partial support for KeyValue records with separate schema for Key and Value is provided by https://github.com/apache/pulsar/blob/3b2c8526a96fc90e948dbeb510e8400a628c749a/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/KVRecord.java#L31 but it looks useful only to Sources it is used for Kafka Connect Source, that encodes directly the key and the value to byte[] https://github.com/apache/pulsar/blob/86e39a25e961d148a485be4a7c9fc186d5b8f8bc/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java#L76 ---------------------------------------------------------------- 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]
