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 ConfluentRegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord> |
forGeneric(String subject,
org.apache.avro.Schema schema,
String schemaRegistryUrl,
Map<String,?> registryConfigs)
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. |
static <T extends org.apache.avro.specific.SpecificRecord> |
forSpecific(Class<T> tClass,
String subject,
String schemaRegistryUrl,
Map<String,?> registryConfigs)
Creates
AvroSerializationSchema that produces byte arrays that were generated from
Avro schema and writes the writer schema to Confluent Schema Registry. |
checkAvroInitialized, equals, forGeneric, forSpecific, hashCode, serialize
forGeneric, forSpecific, getDatumWriter, getEncoder, getOutputStream, getSchema
clone, finalize, getClass, 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 <T extends org.apache.avro.specific.SpecificRecord> ConfluentRegistryAvroSerializationSchema<T> forSpecific(Class<T> tClass, String subject, String schemaRegistryUrl, @Nullable Map<String,?> registryConfigs)
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 connectregistryConfigs
- map with additional schema registry configs (for example SSL
properties)public 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 connectpublic static ConfluentRegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord> forGeneric(String subject, org.apache.avro.Schema schema, String schemaRegistryUrl, @Nullable Map<String,?> registryConfigs)
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 connectregistryConfigs
- map with additional schema registry configs (for example SSL
properties)Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.