Package com.activeviam.io.data.source

Class CustomKafkaAvroDeserializerObjectTuple

java.lang.Object

io.confluent.kafka.serializers.AbstractKafkaAvroSerDe

io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer

io.confluent.kafka.serializers.KafkaAvroDeserializer

com.activeviam.io.data.source.CustomKafkaAvroDeserializerObjectTuple

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<Object>

public class CustomKafkaAvroDeserializerObjectTuple
extends io.confluent.kafka.serializers.KafkaAvroDeserializer

Customize the deserialize method to reuse GenericDatumReader and GenericObject. Return the Object[] tuple to be published to datastore.

Author:

ActiveViam

Field Summary

Fields inherited from class io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer

SCHEMA_REGISTRY_SCHEMA_VERSION_PROP, useSpecificAvroReader

Fields inherited from class io.confluent.kafka.serializers.AbstractKafkaAvroSerDe

idSize, MAGIC_BYTE, schemaRegistry

Constructor Summary

Constructors

Constructor	Description
CustomKafkaAvroDeserializerObjectTuple()

Method Summary

Modifier and Type	Method	Description
protected Object[]	deserialize(boolean includeSchemaAndVersion, String topic, Boolean isKey, byte[] payload, org.apache.avro.Schema readerSchema)

Methods inherited from class io.confluent.kafka.serializers.KafkaAvroDeserializer

close, configure, deserialize, deserialize

Methods inherited from class io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer

configure, deserialize, deserialize, deserializerConfig, deserializerConfig, deserializeWithSchemaAndVersion

Methods inherited from class io.confluent.kafka.serializers.AbstractKafkaAvroSerDe

configureClientProperties, getById, getBySubjectAndId, getOldSubjectName, getPrimitiveSchemas, getSchema, getSubjectName, register

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CustomKafkaAvroDeserializerObjectTuple

public CustomKafkaAvroDeserializerObjectTuple()

Method Detail

deserialize

protected Object[] deserialize(boolean includeSchemaAndVersion,
                               String topic,
                               Boolean isKey,
                               byte[] payload,
                               org.apache.avro.Schema readerSchema)
                        throws org.apache.kafka.common.errors.SerializationException

Overrides:

deserialize in class io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer

Throws:

org.apache.kafka.common.errors.SerializationException