org.apache.paimon.flink.kafka

Class KafkaLogOptions

java.lang.Object

org.apache.paimon.flink.kafka.KafkaLogOptions

public class KafkaLogOptions
extends Object

Options for kafka log.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	BOOTSTRAP_SERVERS
static ConfigOption<String>	TOPIC

Constructor Summary

Constructors

Constructor and Description
KafkaLogOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

BOOTSTRAP_SERVERS

public static final ConfigOption<String> BOOTSTRAP_SERVERS

TOPIC

public static final ConfigOption<String> TOPIC

Constructor Detail

KafkaLogOptions

public KafkaLogOptions()