org.apache.beam.sdk.io.kafka

Class ConfluentSchemaRegistryDeserializerProvider<T>

java.lang.Object

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

@Experimental(value=SOURCE_SINK)
public class ConfluentSchemaRegistryDeserializerProvider<T>
extends java.lang.Object

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 and Description
Coder<T>	getCoder(CoderRegistry coderRegistry)
Deserializer<T>	getDeserializer(java.util.Map<java.lang.String,?> configs, boolean isKey)
static <T> ConfluentSchemaRegistryDeserializerProvider<T>	of(java.lang.String schemaRegistryUrl, java.lang.String subject)
static <T> ConfluentSchemaRegistryDeserializerProvider<T>	of(java.lang.String schemaRegistryUrl, java.lang.String subject, java.lang.Integer version)

Methods inherited from class java.lang.Object

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

Method Detail

of

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

of

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

getDeserializer

public Deserializer<T> getDeserializer(java.util.Map<java.lang.String,?> configs,
                                       boolean isKey)

getCoder

public Coder<T> getCoder(CoderRegistry coderRegistry)