pratyakshsharma commented on issue #6348: URL: https://github.com/apache/hudi/issues/6348#issuecomment-1210628728
It looks like the deserialization of avro records from kafka topic is not happening properly. I see you are using Apicurio schema registry but trying to use confluent avro deserializer class with it (`hoodie.deltastreamer.source.kafka.value.deserializer.class=io.confluent.kafka.serializers.KafkaAvroDeserializer`). You should probably be using corresponding deserializers for apicurio as highlighted here in debezium docs (https://debezium.io/documentation/reference/stable/configuration/avro.html#about-the-registry). Another thing to note is you are using Sql server and hence written your own custom classes - `org.apache.hudi.utilities.sources.debezium.MssqlDebeziumSource` and `org.apache.hudi.common.model.debezium.MssqlDebeziumAvroPayload`. Can you confirm the deserializer that you are using in your custom source class as well? -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
