jm7647 commented on issue #5454: mysql JDBC Sink - consumer error URL: https://github.com/apache/pulsar/issues/5454#issuecomment-546101921 This is producer code I used based on your sample - still same error: producer = client.create_producer( topic='pulsar-mysql-jdbc-sink-topic', properties={"EVENT": "INSERT"}, schema=AvroSchema(Test)) r = Test(id=1, name="Hello World") producer.send(r)
---------------------------------------------------------------- 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: us...@infra.apache.org With regards, Apache Git Services
