Kafka Connectors Restarter

• Description
• Quick Start Guides
• Container image
• Dependencies
• Environment variables
• Contributing

Description

A container that, through the kafka connect API, checks the state of the connectors and tasks, if necessary, restarts it.

It ignore PAUSED connector so it don't restart failed task of PAUSED connectors.

Supports work in two modes:

• cron job
• sidecar

Quick Start Guides

• Run in kubernetes as a cron job
• Run in kubernetes as a sidecar container

Container image

You can pull image from registries:

• ghcr.io/sentoz/kafka-connect-restart:0.8.1
• docker.io/sentoz/kafka-connect-restart:0.8.1

Dependencies

Required dependencies:

• jq - Command-line JSON processor
• curl - Used to check status connectors in kafka connect api

Environment variables

KAFKA_CONNECT_HOST=localhost
KAFKA_CONNECT_PORT=8083
KAFKA_CONNECT_PROTO=http
KAFKA_CONNECT_USER=''
KAFKA_CONNECT_PASS=''
REQUEST_DELAY=30
SIDECAR_MODE=false

Set values for KAFKA_CONNECT_USER and KAFKA_CONNECT_PASS only if Kafka Connect cluster need basic authentication otherwise don't set them.

Contributing

To contribute to kafka-connect-restart, refer to Contributing(Ru).