org.apache.flink.table.descriptors

Class KafkaValidator

java.lang.Object

org.apache.flink.table.descriptors.ConnectorDescriptorValidator

org.apache.flink.table.descriptors.KafkaValidator

All Implemented Interfaces:

DescriptorValidator

@Internal
public class KafkaValidator
extends ConnectorDescriptorValidator

The validator for Kafka.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECTOR_PROPERTIES
static String	CONNECTOR_PROPERTIES_BOOTSTRAP_SERVER
static String	CONNECTOR_PROPERTIES_GROUP_ID
static String	CONNECTOR_PROPERTIES_KEY
static String	CONNECTOR_PROPERTIES_VALUE
static String	CONNECTOR_SINK_PARTITIONER
static String	CONNECTOR_SINK_PARTITIONER_CLASS
static String	CONNECTOR_SINK_PARTITIONER_VALUE_CUSTOM
static String	CONNECTOR_SINK_PARTITIONER_VALUE_FIXED
static String	CONNECTOR_SINK_PARTITIONER_VALUE_ROUND_ROBIN
static String	CONNECTOR_SPECIFIC_OFFSETS
static String	CONNECTOR_SPECIFIC_OFFSETS_OFFSET
static String	CONNECTOR_SPECIFIC_OFFSETS_PARTITION
static String	CONNECTOR_STARTUP_MODE
static String	CONNECTOR_STARTUP_MODE_VALUE_EARLIEST
static String	CONNECTOR_STARTUP_MODE_VALUE_GROUP_OFFSETS
static String	CONNECTOR_STARTUP_MODE_VALUE_LATEST
static String	CONNECTOR_STARTUP_MODE_VALUE_SPECIFIC_OFFSETS
static String	CONNECTOR_STARTUP_MODE_VALUE_TIMESTAMP
static String	CONNECTOR_STARTUP_TIMESTAMP_MILLIS
static String	CONNECTOR_TOPIC
static String	CONNECTOR_TYPE_VALUE_KAFKA
static String	CONNECTOR_VERSION_VALUE_010
static String	CONNECTOR_VERSION_VALUE_011
static String	CONNECTOR_VERSION_VALUE_UNIVERSAL

Fields inherited from class org.apache.flink.table.descriptors.ConnectorDescriptorValidator

CONNECTOR, CONNECTOR_PROPERTY_VERSION, CONNECTOR_TYPE, CONNECTOR_VERSION

Constructor Summary

Constructors

Constructor and Description
KafkaValidator()

Method Summary

Modifier and Type	Method and Description
static boolean	hasConciseKafkaProperties(DescriptorProperties descriptorProperties)
static String	normalizeStartupMode(StartupMode startupMode)
void	validate(DescriptorProperties properties) Performs basic validation such as completeness tests.
static Map<Integer,Long>	validateAndParseSpecificOffsetsString(DescriptorProperties descriptorProperties) Parse SpecificOffsets String to Map.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CONNECTOR_TYPE_VALUE_KAFKA

public static final String CONNECTOR_TYPE_VALUE_KAFKA

See Also:

Constant Field Values

CONNECTOR_VERSION_VALUE_010

public static final String CONNECTOR_VERSION_VALUE_010

See Also:

Constant Field Values

CONNECTOR_VERSION_VALUE_011

public static final String CONNECTOR_VERSION_VALUE_011

See Also:

Constant Field Values

CONNECTOR_VERSION_VALUE_UNIVERSAL

public static final String CONNECTOR_VERSION_VALUE_UNIVERSAL

See Also:

Constant Field Values

CONNECTOR_TOPIC

public static final String CONNECTOR_TOPIC

See Also:

Constant Field Values

CONNECTOR_STARTUP_MODE

public static final String CONNECTOR_STARTUP_MODE

See Also:

Constant Field Values

CONNECTOR_STARTUP_MODE_VALUE_EARLIEST

public static final String CONNECTOR_STARTUP_MODE_VALUE_EARLIEST

See Also:

Constant Field Values

CONNECTOR_STARTUP_MODE_VALUE_LATEST

public static final String CONNECTOR_STARTUP_MODE_VALUE_LATEST

See Also:

Constant Field Values

CONNECTOR_STARTUP_MODE_VALUE_GROUP_OFFSETS

public static final String CONNECTOR_STARTUP_MODE_VALUE_GROUP_OFFSETS

See Also:

Constant Field Values

CONNECTOR_STARTUP_MODE_VALUE_SPECIFIC_OFFSETS

public static final String CONNECTOR_STARTUP_MODE_VALUE_SPECIFIC_OFFSETS

See Also:

Constant Field Values

CONNECTOR_STARTUP_MODE_VALUE_TIMESTAMP

public static final String CONNECTOR_STARTUP_MODE_VALUE_TIMESTAMP

See Also:

Constant Field Values

CONNECTOR_SPECIFIC_OFFSETS

public static final String CONNECTOR_SPECIFIC_OFFSETS

See Also:

Constant Field Values

CONNECTOR_SPECIFIC_OFFSETS_PARTITION

public static final String CONNECTOR_SPECIFIC_OFFSETS_PARTITION

See Also:

Constant Field Values

CONNECTOR_SPECIFIC_OFFSETS_OFFSET

public static final String CONNECTOR_SPECIFIC_OFFSETS_OFFSET

See Also:

Constant Field Values

CONNECTOR_STARTUP_TIMESTAMP_MILLIS

public static final String CONNECTOR_STARTUP_TIMESTAMP_MILLIS

See Also:

Constant Field Values

CONNECTOR_PROPERTIES

public static final String CONNECTOR_PROPERTIES

See Also:

Constant Field Values

CONNECTOR_PROPERTIES_BOOTSTRAP_SERVER

public static final String CONNECTOR_PROPERTIES_BOOTSTRAP_SERVER

See Also:

Constant Field Values

CONNECTOR_PROPERTIES_GROUP_ID

public static final String CONNECTOR_PROPERTIES_GROUP_ID

See Also:

Constant Field Values

CONNECTOR_PROPERTIES_KEY

public static final String CONNECTOR_PROPERTIES_KEY

See Also:

Constant Field Values

CONNECTOR_PROPERTIES_VALUE

public static final String CONNECTOR_PROPERTIES_VALUE

See Also:

Constant Field Values

CONNECTOR_SINK_PARTITIONER

public static final String CONNECTOR_SINK_PARTITIONER

See Also:

Constant Field Values

CONNECTOR_SINK_PARTITIONER_VALUE_FIXED

public static final String CONNECTOR_SINK_PARTITIONER_VALUE_FIXED

See Also:

Constant Field Values

CONNECTOR_SINK_PARTITIONER_VALUE_ROUND_ROBIN

public static final String CONNECTOR_SINK_PARTITIONER_VALUE_ROUND_ROBIN

See Also:

Constant Field Values

CONNECTOR_SINK_PARTITIONER_VALUE_CUSTOM

public static final String CONNECTOR_SINK_PARTITIONER_VALUE_CUSTOM

See Also:

Constant Field Values

CONNECTOR_SINK_PARTITIONER_CLASS

public static final String CONNECTOR_SINK_PARTITIONER_CLASS

See Also:

Constant Field Values

Constructor Detail

KafkaValidator

public KafkaValidator()

Method Detail

validate

public void validate(DescriptorProperties properties)

Description copied from interface: DescriptorValidator

Performs basic validation such as completeness tests.

Specified by:

validate in interface DescriptorValidator

Overrides:

validate in class ConnectorDescriptorValidator

normalizeStartupMode

public static String normalizeStartupMode(StartupMode startupMode)

validateAndParseSpecificOffsetsString

public static Map<Integer,Long> validateAndParseSpecificOffsetsString(DescriptorProperties descriptorProperties)

Parse SpecificOffsets String to Map.

SpecificOffsets String format was given as following:

     connector.specific-offsets = partition:0,offset:42;partition:1,offset:300
 

Returns:

SpecificOffsets with Map format, key is partition, and value is offset.

hasConciseKafkaProperties

public static boolean hasConciseKafkaProperties(DescriptorProperties descriptorProperties)