Skip to content

Siddhi Mapper Avro Release 2.2.0
Compare
Choose a tag to compare
@dilini-muthumala dilini-muthumala released this 19 Mar 11:05
· 26 commits to master since this release
v2.2.0
3f5ba59

This Release is compatible with Siddhi 5.x.x

Overview

Siddhi Mapper Avro 2.2.0 release makes the Avro Mapper compatible with the Kafka Avro Producer / Consumer which is provided by Confluent.

Improvements

This release introduces a new (optional) parameter "use.avro.serializer" to the Siddhi AvroSinkMapper.
Set this parameter to true when you use the class "io.confluent.kafka.serializers.KafkaAvroSerializer" as the value serializer when creating the Kafka producer. When it is set to false, "org.apache.kafka.common.serialization.ByteArraySerializer" will be used.

Similarly, this release introduces a new (optional) parameter "use.avro.deserializer" to the Siddhi AvroSourceMapper.
Set this parameter to true when you use the class "io.confluent.kafka.serializers.KafkaAvroDeserializer" as the value deserializer when creating the Kafka consumer configs. When set to false, "org.apache.kafka.common.serialization.ByteArrayDeserializer" will be used.

Complete Changes

Please find the complete changes here

Download

Download the release from here

Assets 2
Loading