org.apache.paimon.flink.action.cdc.kafka

Class KafkaActionUtils

java.lang.Object

org.apache.paimon.flink.action.cdc.kafka.KafkaActionUtils

public class KafkaActionUtils
extends Object

Utils for Kafka Action.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROPERTIES_PREFIX

Constructor Summary

Constructors

Constructor and Description
KafkaActionUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.connector.kafka.source.KafkaSource<CdcSourceRecord>	buildKafkaSource(org.apache.flink.configuration.Configuration kafkaConfig, org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord> deserializationSchema)
static String	findOneTopic(org.apache.flink.configuration.Configuration kafkaConfig)
static DataFormat	getDataFormat(org.apache.flink.configuration.Configuration kafkaConfig)
static MessageQueueSchemaUtils.ConsumerWrapper	getKafkaEarliestConsumer(org.apache.flink.configuration.Configuration kafkaConfig, org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord> deserializationSchema)

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTIES_PREFIX

public static final String PROPERTIES_PREFIX

See Also:

Constant Field Values

Constructor Detail

KafkaActionUtils

public KafkaActionUtils()

Method Detail

buildKafkaSource

public static org.apache.flink.connector.kafka.source.KafkaSource<CdcSourceRecord> buildKafkaSource(org.apache.flink.configuration.Configuration kafkaConfig,
                                                                                                    org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord> deserializationSchema)

getDataFormat

public static DataFormat getDataFormat(org.apache.flink.configuration.Configuration kafkaConfig)

getKafkaEarliestConsumer

public static MessageQueueSchemaUtils.ConsumerWrapper getKafkaEarliestConsumer(org.apache.flink.configuration.Configuration kafkaConfig,
                                                                               org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord> deserializationSchema)

findOneTopic

public static String findOneTopic(org.apache.flink.configuration.Configuration kafkaConfig)