在 kafka-connect docker 启动并运行后运行 bash 脚本答案

【问题标题】：Running a bash script after the kafka-connect docker is up and running在 kafka-connect docker 启动并运行后运行 bash 脚本
【发布时间】：2020-04-20 23:58:39
【问题描述】：

我有以下 docker 文件

FROM confluentinc/cp-kafka-connect:5.3.1

ENV CONNECT_PLUGIN_PATH=/usr/share/java

# JDBC-MariaDB
RUN wget -nv -P /usr/share/java/kafka-connect-jdbc/ https://downloads.mariadb.com/Connectors/java/connector-java-2.4.4/mariadb-java-client-2.4.4.jar

# SNMP Source
RUN wget -nv -P /tmp/ https://github.com/KarthikDuggirala/kafka-connect-snmp/releases/download/0.0.1.11/kafka-connect-snmp-0.0.1.11.tar.gz
RUN mkdir /tmp/kafka-connect-snmp && tar -xf /tmp/kafka-connect-snmp-0.0.1.11.tar.gz -C /tmp/kafka-connect-snmp/
RUN mv /tmp/kafka-connect-snmp/usr/share/kafka-connect/kafka-connect-snmp /usr/share/java/

# COPY script and make it executable
COPY plugins-config.sh /usr/share/kafka-connect-script/plugins-config.sh
RUN ["chmod", "+x", "/usr/share/kafka-connect-script/plugins-config.sh"]

#entrypoint
ENTRYPOINT [ "./usr/share/kafka-connect-script/plugins-config.sh" ]

以及下面的 bash 脚本

#!/bin/bash
#script to configure kafka connect with plugins
#export CONNECT_REST_ADVERTISED_HOST_NAME=localhost
#export CONNECT_REST_PORT=8083
url=http://$CONNECT_REST_ADVERTISED_HOST_NAME:$CONNECT_REST_PORT/connectors
curl_command="curl -s -o /dev/null -w %{http_code} $url"
sleep_second=5
sleep_second_counter=0
max_seconds_to_wait=30

echo "Waiting for Kafka Connect to start listening on localhost"
echo "HOST: $CONNECT_REST_ADVERTISED_HOST_NAME , PORT: $CONNECT_REST_PORT"
while [[ $(eval $curl_command) -eq 000 ]]
 do 
    echo "In"
    echo -e $date " Kafka Connect listener HTTP state: " $(eval $curl_command) " (waiting for 200) $sleep_second_counter"
    echo "Going to sleep for $sleep_second seconds"
    # sleep $sleep_second
    echo "Finished sleeping"
    # ((sleep_second_counter+=$sleep_second))
    echo "Finished counter"
done
echo "Out"
nc -vz $CONNECT_REST_ADVERTISED_HOST_NAME $CONNECT_REST_PORT

我尝试运行 docker 并使用 docker logs 来查看发生了什么，并且我希望脚本会运行并等待 kafka 连接启动。但显然在说几秒钟后，脚本或（我不知道挂的是什么）挂起，我再也看不到任何控制台打印了。

我有点迷失了什么是错的，所以我需要一些关于我缺少什么或者这不是正确的方法的指导

我要做什么

我想定义逻辑，我可以等待 kafka connect 启动然后运行 curl 命令

curl -X POST -H "Content-Type: application/json" --data '{"name":"","config":{"connector.class":"com.github.jcustenborder .kafka.connect.snmp.SnmpTrapSourceConnector","topic":"fm_snmp"}}' http://localhost:8083/connectors

PS：我不能使用 docker-compose 的方式来做，因为有些地方我必须使用 docker run

【问题讨论】：

标签： bash docker apache-kafka apache-kafka-connect

【解决方案1】：

这里的问题是 ENTRYPOINT 将在容器启动时运行，并且会阻止默认的 CMD 运行，因为脚本将循环等待服务器启动，即脚本将永远循环，因为 CMD不会运行。

您需要执行以下操作之一：

在您的 Entrypoint 中启动 kafka 连接服务器，并在 CMD 中启动您的脚本，或者在容器外运行您的脚本 ....

【讨论】：