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 toshouldInferSchema
CreateSourceAsProperties
is requested for the value_formatCreateSourceProperties
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 createdCreateConfigs
is created