nicolo-paganin commented on issue #5454: mysql JDBC Sink - consumer error URL: https://github.com/apache/pulsar/issues/5454#issuecomment-586766992 @sijie Thanks for the reply 1. Yes I was using a custom SerDe class because of a problem with python 2.7 (here https://github.com/apache/pulsar/blob/b8679078dc6632795c4d81cff9caedd316444f17/pulsar-client-cpp/python/pulsar/functions/serde.py#L77, that `.encode('utf-8')` is not compatible with python 2.7 since in 2.7 strings are already byte strings). Now I am using Python 3.x so I just removed that cusotm SerDe class and tried again. Unfortunately I have the same error 2. Yes I forgot to say that I did some modifcation in the `python-instance` you can find it here in my fork https://github.com/nicolo-paganin/pulsar/commit/ca45931ae47bf9f9eec5ad2cd64e043854ca3024. I am not sure if the modification is considering all cases and if it is good, anyway it was a try. I will try your advice and let you know
---------------------------------------------------------------- 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
