c
pl.touk.nussknacker.engine.schemedkafka.schemaregistry.confluent.serialization
ConfluentKafkaAvroSerializer
Companion object ConfluentKafkaAvroSerializer
class ConfluentKafkaAvroSerializer extends AbstractConfluentKafkaAvroSerializer with Serializer[Any]
This is Kafka Avro Serializer class. All events will be serialized to provided schema.
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- ConfluentKafkaAvroSerializer
- Serializer
- AbstractConfluentKafkaAvroSerializer
- DatumReaderWriterMixin
- AbstractKafkaAvroSerializer
- AbstractKafkaSchemaSerDe
- Closeable
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new ConfluentKafkaAvroSerializer(kafkaConfig: KafkaConfig, confluentSchemaRegistryClient: ConfluentSchemaRegistryClient, schemaEvolutionHandler: AvroSchemaEvolution, avroSchemaOpt: Option[AvroSchema], _isKey: Boolean)
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
- Definition Classes
- AbstractConfluentKafkaAvroSerializer
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
def
close(): Unit
- Definition Classes
- ConfluentKafkaAvroSerializer → Serializer → AbstractKafkaSchemaSerDe → Closeable → AutoCloseable
-
def
configure(configs: Map[String, _], isKey: Boolean): Unit
- Definition Classes
- ConfluentKafkaAvroSerializer → Serializer
-
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
- Definition Classes
- AbstractConfluentKafkaAvroSerializer
-
def
encoderToUse(schema: Schema, out: OutputStream): Encoder
- Attributes
- protected
- Definition Classes
- AbstractConfluentKafkaAvroSerializer
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
executeMigrations(arg0: List[Migration], arg1: String, arg2: String, arg3: Headers, arg4: Any): AnyRef
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] )
-
def
executeRules(arg0: String, arg1: String, arg2: Headers, arg3: Any, arg4: RuleMode, arg5: ParsedSchema, arg6: ParsedSchema, arg7: Any): AnyRef
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
-
def
executeRules(arg0: String, arg1: String, arg2: Headers, arg3: RuleMode, arg4: ParsedSchema, arg5: ParsedSchema, arg6: Any): AnyRef
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
-
def
getByteBuffer(arg0: Array[Byte]): ByteBuffer
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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( ... )
-
def
getMigrations(arg0: String, arg1: ParsedSchema, arg2: ParsedSchema): List[Migration]
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] ) @throws( ... )
-
def
getOldSubjectName(arg0: Any): 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( ... )
-
def
getSchemaBySubjectAndId(arg0: String, arg1: Int): ParsedSchema
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] ) @throws( ... )
-
def
getSubjectName(arg0: String, arg1: Boolean, arg2: Any, arg3: ParsedSchema): String
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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( ... )
-
def
lookupSchemaBySubjectAndId(arg0: String, arg1: Int, arg2: ParsedSchema, arg3: Boolean): ParsedSchema
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] ) @throws( ... )
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
postOp(arg0: Any): 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( ... )
-
def
register(arg0: String, arg1: ParsedSchema): Int
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] ) @throws( ... )
-
def
registerWithResponse(arg0: String, arg1: ParsedSchema, arg2: Boolean): Schema
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] ) @throws( ... )
-
def
serialize(topic: String, headers: Headers, data: Any): Array[Byte]
- Definition Classes
- ConfluentKafkaAvroSerializer → Serializer
-
def
serialize(topic: String, data: Any): Array[Byte]
- Definition Classes
- ConfluentKafkaAvroSerializer → Serializer
-
def
serialize(avroSchemaOpt: Option[AvroSchema], topic: String, data: Any, isKey: Boolean, headers: Headers): Array[Byte]
- Definition Classes
- AbstractConfluentKafkaAvroSerializer
-
def
serializeImpl(arg0: String, arg1: String, arg2: Headers, arg3: Any, arg4: AvroSchema): Array[Byte]
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaAvroSerializer
- Annotations
- @throws( ... ) @throws( ... )
-
def
serializeImpl(arg0: String, arg1: Any, arg2: AvroSchema): Array[Byte]
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaAvroSerializer
- Annotations
- @throws( ... ) @throws( ... )
-
def
serializerConfig(arg0: Properties): KafkaAvroSerializerConfig
- Attributes
- protected[serializers]
- Definition Classes
- AbstractKafkaAvroSerializer
-
def
serializerConfig(arg0: Map[String, _]): 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( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
writeData(data: Any, avroSchema: Schema, schemaId: SchemaId, headers: Headers): Array[Byte]
- Attributes
- protected
- Definition Classes
- AbstractConfluentKafkaAvroSerializer
-
def
writeHeader(schemaId: SchemaId, out: OutputStream, headers: Headers): Unit
- Attributes
- protected
- Definition Classes
- AbstractConfluentKafkaAvroSerializer
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
def
getById(arg0: Int): Schema
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] ) @throws( ... ) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
def
getBySubjectAndId(arg0: String, arg1: Int): Schema
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] ) @throws( ... ) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
def
register(arg0: String, arg1: Schema): Int
- Definition Classes
- AbstractKafkaSchemaSerDe
- Annotations
- @throws( classOf[java.io.IOException] ) @throws( ... ) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.