Package org.apache.kafka.connect.sink

Class SinkTask

java.lang.Object

org.apache.kafka.connect.sink.SinkTask

All Implemented Interfaces:

Task

public abstract class SinkTask
extends java.lang.Object
implements Task

SinkTask is a Task that takes records loaded from Kafka and sends them to another system. Each task instance is assigned a set of partitions by the Connect framework and will handle all records received from those partitions. As records are fetched from Kafka, they will be passed to the sink task using the put(Collection) API, which should either write them to the downstream system or batch them for later writing. Periodically, Connect will call