GenericSerdeFactory¶

Creating Instance¶

GenericSerdeFactory takes the following to be created:

• Format factory (FormatFactory.of)

GenericSerdeFactory is created along with the following:

• GenericKeySerDe
• GenericRowSerDe

Creating Format Serde¶

Serde<List<?>> createFormatSerde(
  String target,
  FormatInfo formatInfo,
  PersistenceSchema schema,
  KsqlConfig ksqlConfig,
  Supplier<SchemaRegistryClient> schemaRegistryClientFactory,
  boolean isKey)

createFormatSerde creates a Format (using the factory for the given FormatInfo) to get a Serde for the given PersistenceSchema.

In case of any exception, createFormatSerde throws a SchemaNotSupportedException:

[target] format does not support schema.
format: [name]
schema: [schema]
reason: [reason]

createFormatSerde is used when:

• GenericKeySerDe is requested to createInner
• GenericRowSerDe is requested to create a Serde