Kafka Connect - Task

Converter Basics


Task is a connector implementation on how data is copied to or from Kafka


These tasks have no state stored within them. Task state is stored in Kafka in special topics and managed by the associated connector.


When a worker fails, tasks are rebalanced across the active workers. When a task fails, no rebalance is triggered as a task failure is considered an exceptional case. As such, failed tasks are not automatically restarted by the framework and should be restarted via the REST API.

Discover More
Converter Basics
Kafka - Connect

Kafka Connect is a framework service based around connector to move data into and out of Kafka. The service is a worker. By starting a worker, you are starting connect. The management is done through...
Converter Basics
Kafka Connect - Connector Plugin

Connector is a component of the connect framework that coordinates data streaming by managing tasks A connector instance is a logical job. Each connector instance coordinates a set of tasks that actually...
Worker Model Basics
Kafka Connect - Distributed Worker

The runtime distributed mode of connect when running/starting a worker See where: worker.properties is the configuration file New workers will either start a new group or join an existing...
Converter Basics
Kafka Connect - REST API

The Connect Rest api is the management interface for the connect service. Unlike many other systems, all nodes in Kafka Connect can respond to REST requests, including creating, listing, modifying, and...
Converter Basics
Kafka Connect - Worker

A worker is a connect component. It is the running process (JVM processes) that execute tasks of a connector. A worker may run several connectors. There is two types of runtime workers: standalone:...

Share this page:
Follow us:
Task Runner