c
pl.touk.nussknacker.engine.schemedkafka.schemaregistry.confluent.serialization
AbstractConfluentKafkaAvroSerializer
class AbstractConfluentKafkaAvroSerializer extends AbstractKafkaAvroSerializer with DatumReaderWriterMixin
Abstract confluent serializer class. Serialize algorithm is copy past from AbstractKafkaAvroSerializer.serializeImpl. Serializer try convert data (in most cases it will be GenericContainer) to indicated schema.
There is some problem when GenericContainer has different schema then final schema - DatumWriter throws exception, because data could not support field from schema. When this situation has place wy try to convert data to provided schema by using AvroSchemaEvolution.alignRecordToSchema implementation.
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- AbstractConfluentKafkaAvroSerializer
- DatumReaderWriterMixin
- AbstractKafkaAvroSerializer
- AbstractKafkaSchemaSerDe
- Closeable
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new AbstractConfluentKafkaAvroSerializer(avroSchemaEvolution: AvroSchemaEvolution)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def autoRegisterSchemaIfNeeded(topic: String, data: Any, isKey: Boolean, avroSchema: AvroSchema): SchemaId
- Attributes
- protected
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def close(): Unit
- Definition Classes
- AbstractKafkaSchemaSerDe → Closeable → AutoCloseable
- Annotations
- @throws(classOf[java.io.IOException])
- def configure(arg0: KafkaAvroSerializerConfig): Unit
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaAvroSerializer
- def configureClientProperties(arg0: AbstractKafkaSchemaSerDeConfig, arg1: SchemaProvider): Unit
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def createDatumReader(writerSchema: Schema, readerSchema: Schema): DatumReader[AnyRef]
- Definition Classes
- DatumReaderWriterMixin
- def createDatumWriter(schema: Schema): GenericDatumWriter[Any]
- Definition Classes
- DatumReaderWriterMixin
- val encoderFactory: EncoderFactory
- Attributes
- protected
- def encoderToUse(schema: Schema, out: OutputStream): Encoder
- Attributes
- protected
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def executeMigrations(arg0: List[Migration], arg1: String, arg2: String, arg3: Headers, arg4: AnyRef): AnyRef
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException])
- def executeRules(arg0: String, arg1: String, arg2: Headers, arg3: AnyRef, arg4: RuleMode, arg5: ParsedSchema, arg6: ParsedSchema, arg7: AnyRef): AnyRef
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def executeRules(arg0: String, arg1: String, arg2: Headers, arg3: RuleMode, arg4: ParsedSchema, arg5: ParsedSchema, arg6: AnyRef): AnyRef
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def getByteBuffer(arg0: Array[Byte]): ByteBuffer
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def getContextName(arg0: String, arg1: String): String
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def getContextName(arg0: String): String
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def getLatestWithMetadata(arg0: String): ParsedSchema
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- def getMigrations(arg0: String, arg1: ParsedSchema, arg2: ParsedSchema): List[Migration]
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- def getOldSubjectName(arg0: AnyRef): String
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def getRuleActions(): Map[String, Map[String, RuleBase]]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def getRuleExecutors(): Map[String, Map[String, RuleBase]]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def getSchemaById(arg0: Int): ParsedSchema
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- def getSchemaBySubjectAndId(arg0: String, arg1: Int): ParsedSchema
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- def getSubjectName(arg0: String, arg1: Boolean, arg2: AnyRef, arg3: ParsedSchema): String
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def isDeprecatedSubjectNameStrategy(arg0: Boolean): Boolean
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isKey(): Boolean
- Definition Classes
- AbstractKafkaSchemaSerDe
- def latestVersionsCache(): Map[SubjectSchema, ParsedSchema]
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def latestWithMetadataCache(): Map[String, ParsedSchema]
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def lookupLatestVersion(arg0: String, arg1: ParsedSchema, arg2: Boolean): ParsedSchema
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- def lookupSchemaBySubjectAndId(arg0: String, arg1: Int, arg2: ParsedSchema, arg3: Boolean): ParsedSchema
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def postOp(arg0: AnyRef): Unit
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def register(arg0: String, arg1: ParsedSchema, arg2: Boolean): Int
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- def register(arg0: String, arg1: ParsedSchema): Int
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- def registerWithResponse(arg0: String, arg1: ParsedSchema, arg2: Boolean): Schema
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
- def serialize(avroSchemaOpt: Option[AvroSchema], topic: String, data: Any, isKey: Boolean, headers: Headers): Array[Byte]
- def serializeImpl(arg0: String, arg1: String, arg2: Headers, arg3: AnyRef, arg4: AvroSchema): Array[Byte]
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaAvroSerializer
- Annotations
- @throws(classOf[org.apache.kafka.common.errors.SerializationException]) @throws(classOf[org.apache.kafka.common.errors.InvalidConfigurationException])
- def serializeImpl(arg0: String, arg1: AnyRef, arg2: AvroSchema): Array[Byte]
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaAvroSerializer
- Annotations
- @throws(classOf[org.apache.kafka.common.errors.SerializationException]) @throws(classOf[org.apache.kafka.common.errors.InvalidConfigurationException])
- def serializerConfig(arg0: Properties): KafkaAvroSerializerConfig
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaAvroSerializer
- def serializerConfig(arg0: Map[String, _ <: AnyRef]): KafkaAvroSerializerConfig
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaAvroSerializer
- def strategyUsesSchema(arg0: Boolean): Boolean
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def ticker(arg0: io.confluent.kafka.schemaregistry.client.SchemaRegistryClient): Ticker
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def writeData(data: Any, avroSchema: Schema, schemaId: SchemaId, headers: Headers): Array[Byte]
- Attributes
- protected
- def writeHeader(schemaId: SchemaId, out: OutputStream, headers: Headers): Unit
- Attributes
- protected
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def getById(arg0: Int): Schema
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
- Deprecated
- def getBySubjectAndId(arg0: String, arg1: Int): Schema
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
- Deprecated
- def register(arg0: String, arg1: Schema): Int
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
- Deprecated