KafkaSerdeFactory¶

Serdes Registry¶

KafkaSerdeFactory defines SERDE registry of Serdes (Apache Kafka) that are supported by KafkaFormat.

containsSerde¶

boolean containsSerde(
  Class<?> javaType)

containsSerde is true when the given javaType is in SERDE registry.

containsSerde is used when:

• KafkaFormat is requested to supportsKeyType

Creating Serde¶

Serde<List<?>> createSerde(
  PersistenceSchema schema)

createSerde returns a KsqlVoidSerde for no columns in the given PersistenceSchema.

createSerde throws a KsqlException for two or more columns in the given PersistenceSchema:

The 'KAFKA' format only supports a single field. Got: [columns]

createSerde converts the SQL type of the single column (in the schema) to a Java type and creates a Serde.

createSerde is used when:

• KafkaFormat is requested for a Serde for a given schema

createSerde¶

<T> Serde<List<?>> createSerde(
  SimpleColumn singleColumn,
  Class<T> javaType)

createSerde...FIXME