Skip to content

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
Back to top