Package org.apache.iceberg.connect
Class IcebergSinkConnector
- java.lang.Object
-
- org.apache.kafka.connect.connector.Connector
-
- org.apache.kafka.connect.sink.SinkConnector
-
- org.apache.iceberg.connect.IcebergSinkConnector
-
- All Implemented Interfaces:
org.apache.kafka.connect.components.Versioned
public class IcebergSinkConnector extends org.apache.kafka.connect.sink.SinkConnector
-
-
Constructor Summary
Constructors Constructor Description IcebergSinkConnector()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.kafka.common.config.ConfigDef
config()
void
start(java.util.Map<java.lang.String,java.lang.String> connectorProps)
void
stop()
java.lang.Class<? extends org.apache.kafka.connect.connector.Task>
taskClass()
java.util.List<java.util.Map<java.lang.String,java.lang.String>>
taskConfigs(int maxTasks)
java.lang.String
version()
-
-
-
Method Detail
-
version
public java.lang.String version()
-
start
public void start(java.util.Map<java.lang.String,java.lang.String> connectorProps)
- Specified by:
start
in classorg.apache.kafka.connect.connector.Connector
-
taskClass
public java.lang.Class<? extends org.apache.kafka.connect.connector.Task> taskClass()
- Specified by:
taskClass
in classorg.apache.kafka.connect.connector.Connector
-
taskConfigs
public java.util.List<java.util.Map<java.lang.String,java.lang.String>> taskConfigs(int maxTasks)
- Specified by:
taskConfigs
in classorg.apache.kafka.connect.connector.Connector
-
stop
public void stop()
- Specified by:
stop
in classorg.apache.kafka.connect.connector.Connector
-
config
public org.apache.kafka.common.config.ConfigDef config()
- Specified by:
config
in classorg.apache.kafka.connect.connector.Connector
-
-