org.apache.paimon.flink.kafka

Class KafkaLogStoreRegister

java.lang.Object

org.apache.paimon.flink.kafka.KafkaLogStoreRegister

All Implemented Interfaces:

LogStoreRegister

public class KafkaLogStoreRegister
extends Object
implements LogStoreRegister

KafkaLogStoreRegister is used to register/unregister topics in Kafka for paimon table.

Constructor Summary

Constructors

Constructor and Description
KafkaLogStoreRegister(LogStoreTableFactory.RegisterContext context)

Method Summary

Modifier and Type	Method and Description
Map<String,String>	registerTopic() Register topic in log system for the table.
void	unRegisterTopic() Unregister topic in log system for the table.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.flink.log.LogStoreRegister

getLogStoreRegister, registerLogSystem, unRegisterLogSystem

Constructor Detail

KafkaLogStoreRegister

public KafkaLogStoreRegister(LogStoreTableFactory.RegisterContext context)

Method Detail

registerTopic

public Map<String,String> registerTopic()

Description copied from interface: LogStoreRegister

Register topic in log system for the table.

Specified by:

registerTopic in interface LogStoreRegister

unRegisterTopic

public void unRegisterTopic()

Description copied from interface: LogStoreRegister

Unregister topic in log system for the table.

Specified by:

unRegisterTopic in interface LogStoreRegister