CommonCreateConfigs¶

FORMAT¶

KAFKA_TOPIC¶

The topic that stores the data of the source

Default: (undefined)

TIMESTAMP_FORMAT¶

VALUE_FORMAT¶

The format of the serialized value

Default: (undefined)

Overrides KsqlConfig.KSQL_DEFAULT_VALUE_FORMAT_CONFIG

Must not be specified with FORMAT

Used when:

• DefaultSchemaInjector is requested to shouldInferSchema
• CreateSourceAsProperties is requested for the value_format
• CreateSourceProperties is requested for the value_format and to withFormats

PARTITIONS¶

The number of partitions in the backing topic. Required if creating a source without an existing topic.

Default: (undefined)

addToConfigDef¶

void addToConfigDef(
  ConfigDef configDef,
  boolean topicNameRequired)

addToConfigDef defines configuration properties (in the given ConfigDef).

addToConfigDef is used when:

• CreateAsConfigs is created
• CreateConfigs is created