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

Interface DeserializerProvider<T>

All Superinterfaces:

Serializable

All Known Implementing Classes:

ConfluentSchemaRegistryDeserializerProvider

public interface DeserializerProvider<T>
extends Serializable

Provides a configured Deserializer instance and its associated Coder.

Method Summary

Modifier and Type	Method	Description
Coder<T>	getCoder(CoderRegistry coderRegistry)
Deserializer<T>	getDeserializer(Map<String,?> configs, boolean isKey)

Method Details

getDeserializer

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

getCoder

Coder<T> getCoder(CoderRegistry coderRegistry)