io.simplesource.saga.serialization.avro

Class GenericSerdeUtils

java.lang.Object

io.simplesource.saga.serialization.avro.GenericSerdeUtils

public final class GenericSerdeUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
GenericSerdeUtils()

Method Summary

Modifier and Type	Method and Description
static <T extends org.apache.avro.generic.GenericRecord> org.apache.kafka.common.serialization.Serde<T>	genericAvroSerde(String schemaRegistryUrl, Boolean isSerdeForRecordKeys)
static <T extends org.apache.avro.generic.GenericRecord> org.apache.kafka.common.serialization.Serde<T>	genericAvroSerde(String schemaRegistryUrl, 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

GenericSerdeUtils

public GenericSerdeUtils()

Method Detail

genericAvroSerde

public static <T extends org.apache.avro.generic.GenericRecord> org.apache.kafka.common.serialization.Serde<T> genericAvroSerde(String schemaRegistryUrl,
                                                                                                                                Boolean isSerdeForRecordKeys)

genericAvroSerde

public static <T extends org.apache.avro.generic.GenericRecord> org.apache.kafka.common.serialization.Serde<T> genericAvroSerde(String schemaRegistryUrl,
                                                                                                                                Boolean isSerdeForRecordKeys,
                                                                                                                                io.confluent.kafka.schemaregistry.client.SchemaRegistryClient registryClient)