Hi, has anyone been able to use io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializer
or io.confluent.kafka.serializers.KafkaAvroDeserializer
?
I’m trying to create a flow that consumes from a topic that uses these “schema aware” payloads, where the Schema is registered in Confluent Schema Registry.
I’ve been looking at configuring
"deserializerType": "expression",
"deserializerDelegateExpression" : "${myCustomDeserializer}",
"payloadExtractorDelegateExpression":"${myPayloadExtractor}",
"channelEventKeyDetection": {
"delegateExpression": "${myChannelEventKeyDetection}"
},
I can implement myCustomDeserializer
and myChannelEventKeyDetection
, but not sure what to do on myPayloadExtractor
.
Thanks, Ramiro