diff options
author | Ram Krishna Verma <ram_krishna.verma@bell.ca> | 2022-11-17 15:54:42 -0500 |
---|---|---|
committer | Ram Krishna Verma <ram_krishna.verma@bell.ca> | 2022-11-28 15:31:30 +0000 |
commit | c398855ed5c271d08f10e492844f0832b0df7ce4 (patch) | |
tree | 413f6d1f96938d4b5a33520b42ed8d8e48c86f8b | |
parent | d8d9369b67f1a39edadcaf81986609c85ff6d21f (diff) |
Add documents for KafkaAvroSerializer support in apex-pdpistanbul
Issue-ID: POLICY-4460
Change-Id: Ica77ff1aafd10b098bdcae72041f3176b29dac40
Signed-off-by: Ram Krishna Verma <ram_krishna.verma@bell.ca>
(cherry picked from commit d873084e17de71c8ef61e844083a2e8d4e32773e)
-rw-r--r-- | docs/apex/APEX-User-Manual.rst | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/docs/apex/APEX-User-Manual.rst b/docs/apex/APEX-User-Manual.rst index eed350ab..93af5aca 100644 --- a/docs/apex/APEX-User-Manual.rst +++ b/docs/apex/APEX-User-Manual.rst @@ -2599,6 +2599,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", + "<url of the schema registry configured in Kafka cluster for registering Avro schemas>" + ] + + .. container:: paragraph + + For more details on how to setup schema registry for Kafka cluster, + kindly take a look `here <https://github.com/confluentinc/schema-registry/blob/master/README.md>`__. + + Kafka Output ============ .. container:: paragraph |