Committer

All Known Implementing Classes:: CommitterImpl

public interface Committer

Method Summary

Modifier and Type

Method

Description

default void

close(Collection<org.apache.kafka.common.TopicPartition> closedPartitions)

default void

open(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context, Collection<org.apache.kafka.common.TopicPartition> addedPartitions)

void

save(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)

void

start(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context)

Deprecated.
will be removed in 2.0.0.

void

stop()

Deprecated.
will be removed in 2.0.0.

Method Details
- start
  
  @Deprecated void start(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context)
  
  Deprecated.
  will be removed in 2.0.0. Use open(Catalog, IcebergSinkConfig, SinkTaskContext, Collection) instead.
- open
  
  default void open(Catalog catalog, IcebergSinkConfig config, org.apache.kafka.connect.sink.SinkTaskContext context, Collection<org.apache.kafka.common.TopicPartition> addedPartitions)
- stop
  
  @Deprecated void stop()
  
  Deprecated.
  will be removed in 2.0.0. Use close(Collection) instead.
- close
  
  default void close(Collection<org.apache.kafka.common.TopicPartition> closedPartitions)
- save
  
  void save(Collection<org.apache.kafka.connect.sink.SinkRecord> sinkRecords)