KeySerdeFactory¶

KeySerdeFactory is an abstraction of factories of key serdes.

Contract¶

Creating Key Serde¶

Serde<GenericKey> create(
  FormatInfo format,
  PersistenceSchema schema,
  KsqlConfig ksqlConfig,
  Supplier<SchemaRegistryClient> schemaRegistryClientFactory,
  String loggerNamePrefix,
  ProcessingLogContext processingLogContext,
  Optional<TrackedCallback> tracker)

Serde (Apache Kafka) of GenericRows

See GenericKeySerDe

Used when:

• CreateSourceFactory is requested to validateSerdesCanHandleSchemas
• KafkaConsumerFactory is requested to create a KafkaConsumer
• MaterializationProviderBuilderFactory is requested to buildMaterializationProvider
• RuntimeBuildContext is requested to buildKeySerde
• InsertsSubscriber is requested to createInsertsSubscriber
• InsertValuesExecutor is requested to serializeValue

Creating Windowed Serde¶

Serde<Windowed<GenericKey>> create(
  FormatInfo format,
  WindowInfo window,
  PersistenceSchema schema,
  KsqlConfig ksqlConfig,
  Supplier<SchemaRegistryClient> schemaRegistryClientFactory,
  String loggerNamePrefix,
  ProcessingLogContext processingLogContext,
  Optional<TrackedCallback> tracker)

Serde (Apache Kafka) of Windowed (Kafka Streams) of GenericRows

See GenericKeySerDe

Used when:

• KafkaConsumerFactory is requested to create a KafkaConsumer
• RuntimeBuildContext is requested to buildKeySerde

Implementations¶

• GenericKeySerDe