Details
-
Story
-
Status: Closed
-
Medium
-
Resolution: Done
-
None
-
Policy 2022-09-28->2022-10-12, Policy 2022-10-12->2022-10-26
Description
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