class ConfluentKafkaAvroDeserializer[T] extends AbstractConfluentKafkaAvroDeserializer with Deserializer[T]

This is Kafka Avro Deserialization class. All events will be deserialized to provided schema.

Linear Supertypes
Deserializer[T], Closeable, AutoCloseable, AbstractConfluentKafkaAvroDeserializer, AbstractKafkaAvroDeserializer, AbstractKafkaSchemaSerDe, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConfluentKafkaAvroDeserializer
  2. Deserializer
  3. Closeable
  4. AutoCloseable
  5. AbstractConfluentKafkaAvroDeserializer
  6. AbstractKafkaAvroDeserializer
  7. AbstractKafkaSchemaSerDe
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ConfluentKafkaAvroDeserializer(kafkaConfig: KafkaConfig, schemaData: Option[RuntimeSchemaData[AvroSchema]], confluentSchemaRegistryClient: ConfluentSchemaRegistryClient, _isKey: Boolean, _useSpecificAvroReader: Boolean)

Type Members

  1. class DeserializationContext extends AnyRef
    Attributes
    private[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  6. def close(): Unit
    Definition Classes
    ConfluentKafkaAvroDeserializer → Deserializer → Closeable → AutoCloseable
  7. def configure(configs: Map[String, _], _isKey: Boolean): Unit
    Definition Classes
    ConfluentKafkaAvroDeserializer → Deserializer
  8. def configure(arg0: KafkaAvroDeserializerConfig): Unit
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer
  9. def configureClientProperties(arg0: AbstractKafkaSchemaSerDeConfig, arg1: SchemaProvider): Unit
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
  10. lazy val decoderFactory: DecoderFactory
    Attributes
    protected
    Definition Classes
    AbstractConfluentKafkaAvroDeserializer
  11. def deserialize(topic: String, data: Array[Byte]): T
    Definition Classes
    ConfluentKafkaAvroDeserializer → Deserializer
  12. def deserialize(arg0: String, arg1: Headers, arg2: Array[Byte]): T
    Definition Classes
    Deserializer
  13. def deserialize(topic: String, isKey: Boolean, payload: Array[Byte], readerSchema: Option[RuntimeSchemaData[AvroSchema]]): AnyRef
    Attributes
    protected
    Definition Classes
    AbstractConfluentKafkaAvroDeserializer
  14. def deserialize(arg0: String, arg1: Boolean, arg2: Array[Byte], arg3: Schema): AnyRef
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer
    Annotations
    @throws( ... )
  15. def deserialize(arg0: Array[Byte], arg1: Schema): AnyRef
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer
    Annotations
    @throws( ... )
  16. def deserialize(arg0: Array[Byte]): AnyRef
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer
    Annotations
    @throws( ... )
  17. def deserializeWithSchemaAndVersion(arg0: String, arg1: Boolean, arg2: Array[Byte]): GenericContainerWithVersion
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer
    Annotations
    @throws( ... ) @throws( ... )
  18. def deserializerConfig(arg0: Properties): KafkaAvroDeserializerConfig
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer
  19. def deserializerConfig(arg0: Map[String, _]): KafkaAvroDeserializerConfig
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer
  20. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  22. def getByteBuffer(arg0: Array[Byte]): ByteBuffer
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
  23. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  24. def getContextName(arg0: String, arg1: String): String
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
  25. def getContextName(arg0: String): String
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
  26. def getDatumReader(arg0: Schema, arg1: Schema): DatumReader[_]
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaAvroDeserializer
  27. def getOldSubjectName(arg0: Any): String
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
  28. def getSchemaById(arg0: Int): ParsedSchema
    Definition Classes
    AbstractKafkaSchemaSerDe
    Annotations
    @throws( classOf[java.io.IOException] ) @throws( ... )
  29. def getSchemaBySubjectAndId(arg0: String, arg1: Int): ParsedSchema
    Definition Classes
    AbstractKafkaSchemaSerDe
    Annotations
    @throws( classOf[java.io.IOException] ) @throws( ... )
  30. def getSubjectName(arg0: String, arg1: Boolean, arg2: Any, arg3: ParsedSchema): String
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
  31. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  32. def isDeprecatedSubjectNameStrategy(arg0: Boolean): Boolean
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
  33. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  34. def lookupLatestVersion(arg0: String, arg1: ParsedSchema, arg2: Boolean): ParsedSchema
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
    Annotations
    @throws( classOf[java.io.IOException] ) @throws( ... )
  35. def lookupSchemaBySubjectAndId(arg0: String, arg1: Int, arg2: ParsedSchema, arg3: Boolean): ParsedSchema
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
    Annotations
    @throws( classOf[java.io.IOException] ) @throws( ... )
  36. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  37. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  38. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  39. def read(buffer: ByteBuffer, expectedSchemaData: Option[RuntimeSchemaData[AvroSchema]]): AnyRef
    Attributes
    protected
    Definition Classes
    AbstractConfluentKafkaAvroDeserializer
  40. def register(arg0: String, arg1: ParsedSchema, arg2: Boolean): Int
    Definition Classes
    AbstractKafkaSchemaSerDe
    Annotations
    @throws( classOf[java.io.IOException] ) @throws( ... )
  41. def register(arg0: String, arg1: ParsedSchema): Int
    Definition Classes
    AbstractKafkaSchemaSerDe
    Annotations
    @throws( classOf[java.io.IOException] ) @throws( ... )
  42. def schemaIdSerializationEnabled: Boolean
    Attributes
    protected
    Definition Classes
    ConfluentKafkaAvroDeserializer → AbstractConfluentKafkaAvroDeserializer
  43. def strategyUsesSchema(arg0: Boolean): Boolean
    Attributes
    protected[serializers]
    Definition Classes
    AbstractKafkaSchemaSerDe
  44. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  45. def toString(): String
    Definition Classes
    AnyRef → Any
  46. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  47. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  48. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. 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.

  2. 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.

  3. 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.

  4. 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.

Inherited from Deserializer[T]

Inherited from Closeable

Inherited from AutoCloseable

Inherited from AbstractConfluentKafkaAvroDeserializer

Inherited from AbstractKafkaAvroDeserializer

Inherited from AbstractKafkaSchemaSerDe

Inherited from AnyRef

Inherited from Any

Ungrouped