Package org.apache.beam.sdk.io.kafka

Class ConfluentSchemaRegistryDeserializerProvider<T>

java.lang.Object

org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProvider<T>

All Implemented Interfaces:

Serializable, DeserializerProvider<T>

public class ConfluentSchemaRegistryDeserializerProvider<T>
extends Object
implements DeserializerProvider<T>

A DeserializerProvider that uses Confluent Schema Registry to resolve a Deserializers and Coder given a subject.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
Coder<T>	getCoder(CoderRegistry coderRegistry)
Deserializer<T>	getDeserializer(Map<String,?> configs, boolean isKey)
static <T> ConfluentSchemaRegistryDeserializerProvider<T>	of(String schemaRegistryUrl, int schemaRegistryCacheCapacity, String subject)
static <T> ConfluentSchemaRegistryDeserializerProvider<T>	of(String schemaRegistryUrl, int schemaRegistryCacheCapacity, String subject, @Nullable Integer version)
static <T> ConfluentSchemaRegistryDeserializerProvider<T>	of(String schemaRegistryUrl, int schemaRegistryCacheCapacity, String subject, @Nullable Integer version, @Nullable Map<String,?> schemaRegistryConfigs)
static <T> ConfluentSchemaRegistryDeserializerProvider<T>	of(String schemaRegistryUrl, String subject)
static <T> ConfluentSchemaRegistryDeserializerProvider<T>	of(String schemaRegistryUrl, String subject, @Nullable Integer version)
static <T> ConfluentSchemaRegistryDeserializerProvider<T>	of(String schemaRegistryUrl, String subject, @Nullable Integer version, @Nullable Map<String,?> schemaRegistryConfigs)

Methods inherited from class java.lang.Object

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

Method Details

of

public static <T>
ConfluentSchemaRegistryDeserializerProvider<T> of(String schemaRegistryUrl,
 String subject)

of

public static <T>
ConfluentSchemaRegistryDeserializerProvider<T> of(String schemaRegistryUrl,
 String subject,
 @Nullable Integer version)

of

public static <T>
ConfluentSchemaRegistryDeserializerProvider<T> of(String schemaRegistryUrl,
 String subject,
 @Nullable Integer version,
 @Nullable Map<String,?> schemaRegistryConfigs)

of

public static <T>
ConfluentSchemaRegistryDeserializerProvider<T> of(String schemaRegistryUrl,
 int schemaRegistryCacheCapacity,
 String subject)

of

public static <T>
ConfluentSchemaRegistryDeserializerProvider<T> of(String schemaRegistryUrl,
 int schemaRegistryCacheCapacity,
 String subject,
 @Nullable Integer version)

of

public static <T>
ConfluentSchemaRegistryDeserializerProvider<T> of(String schemaRegistryUrl,
 int schemaRegistryCacheCapacity,
 String subject,
 @Nullable Integer version,
 @Nullable Map<String,?> schemaRegistryConfigs)

getDeserializer

public Deserializer<T> getDeserializer(Map<String,?> configs,
 boolean isKey)

Specified by:

getDeserializer in interface DeserializerProvider<T>

getCoder

public Coder<T> getCoder(CoderRegistry coderRegistry)

Specified by:

getCoder in interface DeserializerProvider<T>