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: [email protected] With regards, Apache Git Services
