X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=docs%2Fapex%2FAPEX-User-Manual.rst;h=79232042be98b83dd59e206a357745f2d0e14a69;hb=d873084e17de71c8ef61e844083a2e8d4e32773e;hp=c0a7aaca054acae4fca299b0f1555489abe1fb67;hpb=664c0b827ada2cb7eb399a62a1eba39606ddd9db;p=policy%2Fparent.git diff --git a/docs/apex/APEX-User-Manual.rst b/docs/apex/APEX-User-Manual.rst index c0a7aaca..79232042 100644 --- a/docs/apex/APEX-User-Manual.rst +++ b/docs/apex/APEX-User-Manual.rst @@ -2626,6 +2626,31 @@ Kafka Input Kindly note that the above Kafka properties is just a reference, and the actual properties required depends on the Kafka server installation. + In cases where the message produced in Kafka topic has been serialized using KafkaAvroSerializer, + then the following parameters needs to be additionally added to `KafkaProperties` for the consumer + to have the capability of deserializing the message properly while consuming. + + .. container:: listingblock + + .. container:: content + + .. code:: + + [ + "value.deserializer", + "io.confluent.kafka.serializers.KafkaAvroDeserializer" + ], + [ + "schema.registry.url", + "" + ] + + .. container:: paragraph + + For more details on how to setup schema registry for Kafka cluster, + kindly take a look `here `__. + + Kafka Output ============ .. container:: paragraph