T
- the type to be serializedpublic class ConfluentRegistryAvroSerializationSchema<T> extends RegistryAvroSerializationSchema<T>
SerializationSchema.InitializationContext
schemaCoder
Modifier and Type | Method and Description |
---|---|
static ConfluentRegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord> |
forGeneric(String subject,
org.apache.avro.Schema schema,
String schemaRegistryUrl)
Creates
AvroSerializationSchema that produces byte arrays that were generated from
avro schema and writes the writer schema to Confluent Schema Registry. |
static <T extends org.apache.avro.specific.SpecificRecord> |
forSpecific(Class<T> tClass,
String subject,
String schemaRegistryUrl)
Creates
AvroSerializationSchema that produces byte arrays that were generated from
avro schema and writes the writer schema to Confluent Schema Registry. |
checkAvroInitialized, forGeneric, forSpecific, serialize
forGeneric, forSpecific, getDatumWriter, getEncoder, getOutputStream, getSchema
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open
public static <T extends org.apache.avro.specific.SpecificRecord> ConfluentRegistryAvroSerializationSchema<T> forSpecific(Class<T> tClass, String subject, String schemaRegistryUrl)
AvroSerializationSchema
that produces byte arrays that were generated from
avro schema and writes the writer schema to Confluent Schema Registry.tClass
- the type to be serializedsubject
- subject of schema registry to produceschemaRegistryUrl
- url of schema registry to connectpublic static ConfluentRegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord> forGeneric(String subject, org.apache.avro.Schema schema, String schemaRegistryUrl)
AvroSerializationSchema
that produces byte arrays that were generated from
avro schema and writes the writer schema to Confluent Schema Registry.subject
- subject of schema registry to produceschema
- schema that will be used for serializationschemaRegistryUrl
- url of schema registry to connectCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.