Package org.apache.flink.cdc.connectors.kafka.utils

Class KafkaSinkUtils

java.lang.Object

org.apache.flink.cdc.connectors.kafka.utils.KafkaSinkUtils

public class KafkaSinkUtils
extends Object

Util class for KafkaDataSink.

Constructor Summary

Constructors

Constructor	Description
KafkaSinkUtils()

Method Summary

Modifier and Type	Method	Description
static Map<Selectors,String>	parseSelectorsToTopicMap(String mappingRuleString)	Parse the mapping text to a map from Selectors to Kafka Topic name.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSinkUtils

public KafkaSinkUtils()

Method Detail

parseSelectorsToTopicMap

public static Map<Selectors,String> parseSelectorsToTopicMap(String mappingRuleString)

Parse the mapping text to a map from Selectors to Kafka Topic name.