Package org.apache.storm.hdfs.avro
Class ConfluentAvroSerializer
java.lang.Object
com.esotericsoftware.kryo.Serializer<org.apache.avro.generic.GenericContainer>
org.apache.storm.hdfs.avro.AbstractAvroSerializer
org.apache.storm.hdfs.avro.ConfluentAvroSerializer
- All Implemented Interfaces:
Serializable
,AvroSchemaRegistry
This class provides a mechanism to utilize the Confluent Schema Registry (https://github.com/confluentinc/schema-registry)
for Storm to (de)serialize Avro generic records across a topology. It assumes the schema registry is up and running
completely independent of Storm.
- See Also:
-
Constructor Summary
ConstructorDescriptionConfluentAvroSerializer
(com.esotericsoftware.kryo.Kryo k, Map<String, Object> topoConf) A constructor with a signature that Storm can locate and use with kryo registration. -
Method Summary
Modifier and TypeMethodDescriptiongetFingerprint
(org.apache.avro.Schema schema) org.apache.avro.Schema
Methods inherited from class org.apache.storm.hdfs.avro.AbstractAvroSerializer
read, write
Methods inherited from class com.esotericsoftware.kryo.Serializer
copy, getAcceptsNull, isImmutable, setAcceptsNull, setImmutable
-
Constructor Details
-
ConfluentAvroSerializer
A constructor with a signature that Storm can locate and use with kryo registration. See Storm's SerializationFactory class for details- Parameters:
k
- Unused but needs to be present for Serialization Factory to find this constructortopoConf
- The global storm configuration. Must define "avro.schemaregistry.confluent" to locate the confluent schema registry. Should in the form of "http://HOST:PORT"
-
-
Method Details
-
getFingerprint
-
getSchema
-