Package org.apache.iceberg.connect

Class IcebergSinkConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

org.apache.iceberg.connect.IcebergSinkConfig

public class IcebergSinkConfig
extends org.apache.kafka.common.config.AbstractConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.kafka.common.config.ConfigDef	CONFIG_DEF
static final int	CREATE_TABLE_RETRIES
static final String	DEFAULT_CONTROL_GROUP_PREFIX
static final String	INTERNAL_TRANSACTIONAL_SUFFIX_PROP
static final int	SCHEMA_UPDATE_RETRIES

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
IcebergSinkConfig(Map<String,String> originalProps)

Method Summary

Modifier and Type	Method	Description
boolean	autoCreateEnabled()
Map<String,String>	autoCreateProps()
String	catalogName()
Map<String,String>	catalogProps()
int	commitIntervalMs()
int	commitThreads()
int	commitTimeoutMs()
String	connectGroupId()
String	connectorName()
String	controlGroupIdPrefix()
String	controlTopic()
boolean	dynamicTablesEnabled()
boolean	evolveSchemaEnabled()
String	hadoopConfDir()
Map<String,String>	hadoopProps()
org.apache.kafka.connect.json.JsonConverter	jsonConverter()
Map<String,String>	kafkaProps()
long	keepAliveTimeoutInMs()
boolean	schemaCaseInsensitive()
boolean	schemaForceOptional()
TableSinkConfig	tableConfig(String tableName)
List<String>	tables()
String	tablesDefaultCommitBranch()
String	tablesDefaultIdColumns()
String	tablesDefaultPartitionBy()
String	tablesRouteField()
String	taskId()
String	transactionalPrefix()
String	transactionalSuffix()
static String	version()
Map<String,String>	writeProps()

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

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

Field Details

INTERNAL_TRANSACTIONAL_SUFFIX_PROP

public static final String INTERNAL_TRANSACTIONAL_SUFFIX_PROP

See Also:

• Constant Field Values

DEFAULT_CONTROL_GROUP_PREFIX

public static final String DEFAULT_CONTROL_GROUP_PREFIX

See Also:

• Constant Field Values

SCHEMA_UPDATE_RETRIES

public static final int SCHEMA_UPDATE_RETRIES

See Also:

• Constant Field Values

CREATE_TABLE_RETRIES

public static final int CREATE_TABLE_RETRIES

See Also:

• Constant Field Values

CONFIG_DEF

public static final org.apache.kafka.common.config.ConfigDef CONFIG_DEF

Constructor Details

IcebergSinkConfig

public IcebergSinkConfig(Map<String,String> originalProps)

Method Details

version

public static String version()

connectorName

public String connectorName()

taskId

public String taskId()

transactionalSuffix

public String transactionalSuffix()

catalogProps

public Map<String,String> catalogProps()

hadoopProps

public Map<String,String> hadoopProps()

kafkaProps

public Map<String,String> kafkaProps()

autoCreateProps

public Map<String,String> autoCreateProps()

writeProps

public Map<String,String> writeProps()

catalogName

public String catalogName()

tables

public List<String> tables()

dynamicTablesEnabled

public boolean dynamicTablesEnabled()

tablesRouteField

public String tablesRouteField()

tablesDefaultCommitBranch

public String tablesDefaultCommitBranch()

tablesDefaultIdColumns

public String tablesDefaultIdColumns()

tablesDefaultPartitionBy

public String tablesDefaultPartitionBy()

keepAliveTimeoutInMs

public long keepAliveTimeoutInMs()

tableConfig

public TableSinkConfig tableConfig(String tableName)

controlTopic

public String controlTopic()

controlGroupIdPrefix

public String controlGroupIdPrefix()

connectGroupId

public String connectGroupId()

commitIntervalMs

public int commitIntervalMs()

commitTimeoutMs

public int commitTimeoutMs()

commitThreads

public int commitThreads()

transactionalPrefix

public String transactionalPrefix()

hadoopConfDir

public String hadoopConfDir()

autoCreateEnabled

public boolean autoCreateEnabled()

evolveSchemaEnabled

public boolean evolveSchemaEnabled()

schemaForceOptional

public boolean schemaForceOptional()

schemaCaseInsensitive

public boolean schemaCaseInsensitive()

jsonConverter

public org.apache.kafka.connect.json.JsonConverter jsonConverter()