Kafka Connectors Restarter

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

Description

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

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.7.1
• quay.io/sentoz/kafka-connect-restart:0.7.1
• docker.io/sentoz/kafka-connect-restart:0.7.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
REQUEST_DELAY=30
SIDECAR_MODE=false