Uploaded image for project: 'Policy Framework'
  1. Policy Framework
  2. POLICY-4369

Support KafkaAvroDeserializer in KafkaConsumer plugin of apex-pdp

XMLWordPrintable

      As a ONAP developer, I would like to add support of KafkaAvroDeserializer in the KafkaConsumer plugin of apex-pdp, in order to support reading messages that were serialized using KafkaAvroSerializer on the producer side.

      By default, KafkaConsumer uses the StringDeserializer which is not able to deserialize the messages serialized using avro schema.

      More details here - https://docs.confluent.io/platform/current/schema-registry/serdes-develop/serdes-avro.html#avro-deserializer

      Apex-PDP Kafka consumer - https://github.com/onap/policy-apex-pdp/blob/master/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/main/java/org/onap/policy/apex/plugins/event/carrier/kafka/ApexKafkaConsumer.java

       

            ramverma ramverma
            ramverma ramverma
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: