Format¶

Format is an abstraction of serialization formats of a Kafka topic in ksqlDB.

Contract¶

Create Serde¶

Serde<List<?>> getSerde(
  PersistenceSchema schema,
  Map<String, String> formatProperties,
  KsqlConfig ksqlConfig,
  Supplier<SchemaRegistryClient> srClientFactory,
  boolean isKey)

Creates a Serde (Apache Kafka) for the given PersistenceSchema

Used when:

• GenericSerdeFactory is requested to create a Serde for a Format

name¶

String name()

supportsKeyType¶

boolean supportsKeyType(
  SqlType type)

Used when:

• SerdeFeaturesFactory is requested to sanitizeKeyFormatForTypeCompatibility

Implementations¶

• ConnectFormat
• DelimitedFormat
• KafkaFormat
• NoneFormat