You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2019/04/03 05:45:06 UTC

[GitHub] [pulsar] sijie commented on issue #3966: UNAVAILABLE: io exception in a Sink which accepts pulsar messages as bytes

sijie commented on issue #3966: UNAVAILABLE: io exception in a Sink which accepts pulsar messages as bytes
URL: https://github.com/apache/pulsar/issues/3966#issuecomment-479348414
 
 
   @murong00 sorry for late response. functions try to infer the schema from the generic type in the identify function. since the identify function doesn't have a specific type and RedisSink also doesn't have a specific type, it hence causes pulsar to use `JSONSchema` by default. In general I would suggest using `Bytes` for most of the connectors (e.g. messaging queues, kv, nosql system and filesystems), and using `GenericRecord` for connectors connecting to systems that have "schema" (e.g. databases). So you are able to get the right schema for connecting data to pulsar. 
   
   

----------------------------------------------------------------
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:
users@infra.apache.org


With regards,
Apache Git Services