Using KafkaJsonSchemaDeserializer for events

Flowable Engine
1

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

2

Hey @ramirogm,

For the custom myPayloadExtractor you’ll need to implement something that would map the object created by your myCustomDeserializer to a list of EventPayloadInstance(s).

We have some customers that are using the schema aware payloads.

Cheers,
Filip