CommonCreateConfigs¶

FORMAT¶

KAFKA_TOPIC¶

The topic that stores the data of the source

Default: (undefined)

KEY_DELIMITER_PROPERTY¶

KEY_FORMAT¶

KEY_SCHEMA_FULL_NAME¶

KEY_SCHEMA_ID¶

Default: (undefined)

Used when:

• DefaultSchemaInjector is requested to forCreateAsStatement, forCreateStatement, shouldInferSchema
• SchemaRegisterInjector is requested to stripSchemaIdConfig, registerForCreateSource, registerForCreateAs, sanityCheck, registerRawSchema
• CreateSourceAsProperties is requested to getKeySchemaId
• CreateSourceProperties is requested to getKeySchemaId

SOURCE_NUMBER_OF_REPLICAS¶

TIMESTAMP_NAME_PROPERTY¶

TIMESTAMP_FORMAT¶

VALUE_AVRO_SCHEMA_FULL_NAME¶

The fully qualified name of the Avro schema to use for values

Default: (undefined)

VALUE_DELIMITER_PROPERTY¶

VALUE_FORMAT¶

The format of serialized values

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

VALUE_SCHEMA_FULL_NAME¶

The fully-qualified name of the schema of serialized values (e.g. com.mycorp.mynamespace.sampleRecord, io.confluent.ksql.avro_schemas)

Default: (undefined)

Must not be specified together with VALUE_AVRO_SCHEMA_FULL_NAME

Used when:

• DefaultSchemaInjector is requested to throwOnMultiSchemaDefinitions
• CreateSourceAsProperties is requested to getValueFormatProperties, withKeyValueSchemaName
• CreateSourceProperties is requested to getValueSchemaFullName, getValueFormatProperties, withKeyValueSchemaName

VALUE_SCHEMA_ID¶

Default: (undefined)

Used when:

• CreateSourceAsProperties is requested for the VALUE_SCHEMA_ID
• CreateSourceProperties is requested for the VALUE_SCHEMA_ID
• DefaultSchemaInjector is requested to forCreateAsStatement, forCreateStatement, shouldInferSchema
• SchemaRegisterInjector is requested to stripSchemaIdConfig, registerForCreateSource, tryGetFormat, registerForCreateAs, sanityCheck, registerRawSchema

WRAP_SINGLE_VALUE¶

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