org.apache.paimon.flink.action.cdc.serialization

Class ConfluentAvroDeserializationSchema

java.lang.Object

io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer

org.apache.paimon.flink.action.cdc.serialization.ConfluentAvroDeserializationSchema

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable

public class ConfluentAvroDeserializationSchema
extends io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer
implements Serializable

A confluent avro deserialization schema for AbstractKafkaAvroDeserializer.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe

io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.Migration, io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.SubjectSchema

Field Summary

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

avroReflectionAllowNull, avroUseLogicalTypeConverters, specificAvroReaderSchema, useSpecificAvroReader

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

config, contextNameStrategy, DEFAULT_CACHE_CAPACITY, enableRuleServiceLoader, idSize, isKey, keySubjectNameStrategy, latestVersions, latestWithMetadata, MAGIC_BYTE, metadata, ruleActions, ruleExecutors, schemaRegistry, ticker, useLatestVersion, useSchemaReflection, valueSubjectNameStrategy

Constructor Summary

Constructors

Constructor and Description
ConfluentAvroDeserializationSchema(io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client)

Method Summary

Modifier and Type	Method and Description
static ConfluentAvroDeserializationSchema	create(String schemaRegistryUrl)
io.confluent.kafka.serializers.GenericContainerWithVersion	deserialize(String topic, boolean isKey, byte[] payload)

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

configure, configure, deserialize, deserialize, deserialize, deserialize, deserializerConfig, deserializerConfig, deserializeWithSchemaAndVersion, deserializeWithSchemaAndVersion, getDatumReader

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

clearKey, close, configureClientProperties, executeMigrations, executeRules, executeRules, getById, getBySubjectAndId, getByteBuffer, getContextName, getContextName, getLatestWithMetadata, getMigrations, getOldSubjectName, getRuleActions, getRuleExecutors, getSchemaById, getSchemaBySubjectAndId, getSubjectName, isDeprecatedSubjectNameStrategy, isKey, key, latestVersionsCache, latestWithMetadataCache, lookupLatestVersion, lookupLatestVersion, lookupSchemaBySubjectAndId, postOp, register, register, register, registerWithResponse, setKey, strategyUsesSchema, ticker, toKafkaException

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfluentAvroDeserializationSchema

public ConfluentAvroDeserializationSchema(io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client)

Method Detail

deserialize

public io.confluent.kafka.serializers.GenericContainerWithVersion deserialize(String topic,
                                                                              boolean isKey,
                                                                              byte[] payload)

create

public static ConfluentAvroDeserializationSchema create(String schemaRegistryUrl)