static ConfluentRegistryAvroSerializationSchema<org.apache.avro.generic.GenericRecord> |
ConfluentRegistryAvroSerializationSchema.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> |
ConfluentRegistryAvroSerializationSchema.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>
ConfluentRegistryAvroSerializationSchema<T> |
ConfluentRegistryAvroSerializationSchema.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>
ConfluentRegistryAvroSerializationSchema<T> |
ConfluentRegistryAvroSerializationSchema.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.
|