/kafka-connect-bash-client

bash client for interacting with the kafka-connect distributed api

Primary LanguageShellApache License 2.0Apache-2.0

KafkaConnect bash client

Setup

This project depends on jq being installed and available within your PATH

Install jq

brew install jq

Update your local PATH

# add bin to path
export PATH="${PATH}:./bin"

Create or Update job

kafka-connect-put-job ./jobs/s3-sink.properties "http://localhost:8083"

Delete existing job

kafka-connect-rm-job "connect-s3" "http://localhost:8083"

Other Operations

source ./bin/kafka-connect-ops

# get status of existing job
kafka-connect-job-status "connect-s3" "http://localhost:8083"