Interface 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
    Deprecated.
    will be removed in 2.0.0.