package schemedkafka

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package encode
  2. package schema
  3. package schemaregistry
  4. package serialization
  5. package sink
  6. package source
  7. package typed

Type Members

  1. class AllTopicsSelectionStrategy extends TopicSelectionStrategy
  2. class AvroDefaultExpressionDeterminer extends AnyRef

  3. trait AvroSchemaDeterminer extends AnyRef
  4. abstract class KafkaUniversalComponentTransformer[T, TN <: TopicName] extends SingleInputDynamicComponent[T] with WithCachedTopicsExistenceValidator
  5. class LogicalTypesGenericRecordBuilder extends RecordBuilderBase[Record]

    A RecordBuilder for generic records.

    A RecordBuilder for generic records. GenericRecordBuilder fills in default values for fields if they are not specified.

  6. case class RuntimeSchemaData[T <: ParsedSchema](serializableSchema: NkSerializableParsedSchema[T], schemaIdOpt: Option[SchemaId]) extends Product with Serializable

    This class holds data that will be passed to Flink's tasks for records processing in runtime.

    This class holds data that will be passed to Flink's tasks for records processing in runtime.

    serializableSchema

    Serializable Avro schema

    schemaIdOpt

    optional schema id fetched from schema registry - for further optimizations of record processing in runtime

  7. class SchemaDeterminerError extends RuntimeException
  8. class TopicPatternSelectionStrategy extends TopicSelectionStrategy
  9. trait TopicSelectionStrategy extends Serializable

Value Members

  1. object AvroDefaultExpressionDeterminer
  2. object AvroUtils extends LazyLogging
  3. object KafkaUniversalComponentTransformer extends Serializable
  4. object RuntimeSchemaData extends Serializable
  5. object SchemaDeterminerErrorHandler

Ungrouped