public class ConfluentAvroDeserializationSchema extends io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer implements Serializable
AbstractKafkaAvroDeserializer
.avroReflectionAllowNull, avroUseLogicalTypeConverters, specificAvroReaderSchema, useSpecificAvroReader
config, contextNameStrategy, DEFAULT_CACHE_CAPACITY, enableRuleServiceLoader, idSize, isKey, keySubjectNameStrategy, latestVersions, latestWithMetadata, MAGIC_BYTE, metadata, ruleActions, ruleExecutors, schemaRegistry, ticker, useLatestVersion, useSchemaReflection, valueSubjectNameStrategy
Constructor and Description |
---|
ConfluentAvroDeserializationSchema(io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client) |
Modifier and Type | Method and Description |
---|---|
static ConfluentAvroDeserializationSchema |
create(String schemaRegistryUrl) |
io.confluent.kafka.serializers.GenericContainerWithVersion |
deserialize(String topic,
boolean isKey,
byte[] payload) |
configure, configure, deserialize, deserialize, deserialize, deserialize, deserializerConfig, deserializerConfig, deserializeWithSchemaAndVersion, deserializeWithSchemaAndVersion, getDatumReader
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
public ConfluentAvroDeserializationSchema(io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client)
public io.confluent.kafka.serializers.GenericContainerWithVersion deserialize(String topic, boolean isKey, byte[] payload)
public static ConfluentAvroDeserializationSchema create(String schemaRegistryUrl)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.