You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "eolivelli (via GitHub)" <gi...@apache.org> on 2023/03/20 16:32:10 UTC

[GitHub] [pulsar] eolivelli commented on pull request #19861: [fix][io] KCA sink: handle null values with KeyValue schema

eolivelli commented on PR #19861:
URL: https://github.com/apache/pulsar/pull/19861#issuecomment-1476566275

    actually in Pulsar a KeyValue<?,?> schema allows null for both the key and the value.
   
   @dlg99 in Pulsar it is not allowed to nest KeyValue schemas. KeyValue schema is a (bad) trick to provide a Schema to the key of the message.
   
   any usage of nested KeyValue schemas is not supported (we may issue a warning or throw an error in Pulsar 3.0) and it cannot work properly
   
   so this schema doesn't work 
   `Schema.KeyValue(Schema.INT32, Schema.KeyValue(Schema.INT32, Schema.KeyValue(Schema.INT32, schema)))`
   


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org