#!/usr/bin/env bash
set -e

CONFIG_FILE=/etc/kafka-connect/connect-distributed.properties
WORKER_SCRIPT=/usr/lib/kafka/bin/connect-distributed.sh

if [ "${CONNECT_MODE:-distributed}" = "standalone" ]; then
  CONFIG_FILE=/etc/kafka-connect/connect-standalone.properties
  WORKER_SCRIPT=/usr/lib/kafka/bin/connect-standalone.sh
fi

# Translate CONNECT_* env vars to properties (CONNECT_BOOTSTRAP_SERVERS -> bootstrap.servers)
for var in $(env | grep '^CONNECT_' | grep -v '^CONNECT_MODE=' | awk -F= '{print $1}'); do
  key=$(echo "$var" | sed 's/^CONNECT_//' | tr '_' '.' | tr '[:upper:]' '[:lower:]')
  value=$(printenv "$var")
  echo "${key}=${value}" >> "$CONFIG_FILE"
done

exec "$WORKER_SCRIPT" "$CONFIG_FILE"
