jiazhai commented on issue #5633: Support Avro schema from Debezium source
connector
URL: https://github.com/apache/pulsar/issues/5633#issuecomment-558050914
This involves convert Avro schema that stores in Kafka registry into Pulsar
readable data. We will provide a fix for this issue.
-
jiazhai commented on issue #5633: Support Avro schema from Debezium source
connector
URL: https://github.com/apache/pulsar/issues/5633#issuecomment-553780339
@tuteng to have a try and help provide a doc of how to do it.
This
jiazhai commented on issue #5633: Support Avro schema from Debezium source
connector
URL: https://github.com/apache/pulsar/issues/5633#issuecomment-553758608
@raghavi92 , Seems need to include related jar into the pom.xml file of
pulsar-debezium to support it.
jiazhai commented on issue #5633: Support Avro schema from Debezium source
connector
URL: https://github.com/apache/pulsar/issues/5633#issuecomment-553325573
@raghavi92 This need to config the `key.converter` and `value.converter`
for the debezium connector. The default converter is Jason
jiazhai commented on issue #5633: Support Avro schema from Debezium source
connector
URL: https://github.com/apache/pulsar/issues/5633#issuecomment-553222808
Please reference
[KeyValueSchema.java](https://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/org/apache/pulsar/cl
jiazhai commented on issue #5633: Support Avro schema from Debezium source
connector
URL: https://github.com/apache/pulsar/issues/5633#issuecomment-553222899
@tuteng Could we add some doc for how to config and use schema in debezium
connector?
-
jiazhai commented on issue #5633: Support Avro schema from Debezium source
connector
URL: https://github.com/apache/pulsar/issues/5633#issuecomment-553222423
@raghavi92 In Debezium, we have to use KeyValueSchema, and inside the
KeyValueSchema, key and value could be avro type.
---
