io.simplesource.kafka.serialization.avro

Class AvroGenericUtils

java.lang.Object

io.simplesource.kafka.serialization.avro.AvroGenericUtils

public final class AvroGenericUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AvroGenericUtils.SchemaNameStrategy
static class	AvroGenericUtils.ValueWithSequenceAvroHelper

Constructor Summary

Constructors

Constructor and Description
AvroGenericUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.GenericRecord>	genericAvroSerde(String schemaRegistryUrl, boolean useMockSchemaRegistry, boolean isKey)
static org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.GenericRecord>	genericAvroSerde(String schemaRegistryUrl, boolean useMockSchemaRegistry, boolean isKey, AvroGenericUtils.SchemaNameStrategy schemaNameStrategy)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroGenericUtils

public AvroGenericUtils()

Method Detail

genericAvroSerde

public static org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.GenericRecord> genericAvroSerde(String schemaRegistryUrl,
                                                                                                                  boolean useMockSchemaRegistry,
                                                                                                                  boolean isKey)

genericAvroSerde

public static org.apache.kafka.common.serialization.Serde<org.apache.avro.generic.GenericRecord> genericAvroSerde(String schemaRegistryUrl,
                                                                                                                  boolean useMockSchemaRegistry,
                                                                                                                  boolean isKey,
                                                                                                                  AvroGenericUtils.SchemaNameStrategy schemaNameStrategy)