io.simplesource.saga.serialization.avro

Class SpecificSerdeUtils

java.lang.Object

io.simplesource.saga.serialization.avro.SpecificSerdeUtils

public final class SpecificSerdeUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
SpecificSerdeUtils()

Method Summary

Modifier and Type	Method and Description
static <T extends org.apache.avro.specific.SpecificRecord> org.apache.kafka.common.serialization.Serde<T>	specificAvroSerde(String registryUrl, Boolean isSerdeForRecordKeys)
static <T extends org.apache.avro.specific.SpecificRecord> org.apache.kafka.common.serialization.Serde<T>	specificAvroSerde(String registryUrl, Boolean isSerdeForRecordKeys, io.confluent.kafka.schemaregistry.client.SchemaRegistryClient registryClient)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpecificSerdeUtils

public SpecificSerdeUtils()

Method Detail

specificAvroSerde

public static <T extends org.apache.avro.specific.SpecificRecord> org.apache.kafka.common.serialization.Serde<T> specificAvroSerde(String registryUrl,
                                                                                                                                   Boolean isSerdeForRecordKeys)

specificAvroSerde

public static <T extends org.apache.avro.specific.SpecificRecord> org.apache.kafka.common.serialization.Serde<T> specificAvroSerde(String registryUrl,
                                                                                                                                   Boolean isSerdeForRecordKeys,
                                                                                                                                   io.confluent.kafka.schemaregistry.client.SchemaRegistryClient registryClient)