c
pl.touk.nussknacker.engine.schemedkafka.schemaregistry.confluent.serialization.jsonpayload
ConfluentJsonPayloadKafkaSerializer
class ConfluentJsonPayloadKafkaSerializer extends ConfluentKafkaAvroSerializer
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ConfluentJsonPayloadKafkaSerializer
- ConfluentKafkaAvroSerializer
- Serializer
- AbstractConfluentKafkaAvroSerializer
- DatumReaderWriterMixin
- AbstractKafkaAvroSerializer
- AbstractKafkaSchemaSerDe
- Closeable
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new ConfluentJsonPayloadKafkaSerializer(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(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- 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
- ConfluentJsonPayloadKafkaSerializer → AbstractConfluentKafkaAvroSerializer
- 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(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: 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
- Definition Classes
- AbstractConfluentKafkaAvroSerializer
- def writeHeader(schemaId: SchemaId, out: OutputStream, headers: Headers): Unit
- Attributes
- protected
- Definition Classes
- ConfluentJsonPayloadKafkaSerializer → AbstractConfluentKafkaAvroSerializer
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