无法 运行 kafka connect datagen inside kafka connect docker image
Unable to run kafka connect datagen inside kafka connect docker image
我正在尝试 运行 kafka-connect 容器内的 kafka datagen 连接器，我的 kafka 驻留在 AWS MSK 中使用：https://github.com/confluentinc/kafka-connect-datagen/blob/master/Dockerfile-confluenthub.
我正在使用 kafdrop 作为 kafka 代理 (MSK) 的 Web 浏览器。我没有看到 Kafka datagen 生成任何测试消息。
除了安装 kafka-datagen 连接器
之外，我还需要做其他配置吗
此外，我如何在 confluentinc/kafka-connect 图像中检查创建了哪些主题以及是否使用了消息？
Docker文件看起来像：
ARG BASE_PREFIX=confluentinc
ARG CONNECT_IMAGE=cp-kafka-connect
FROM $BASE_PREFIX/$CONNECT_IMAGE:6.1.0
ENV CONNECT_PLUGIN_PATH="/usr/share/java,/usr/share/confluent-hub-components"
RUN confluent-hub install --no-prompt confluentinc/kafka-connect-datagen:0.4.0
docker exec 51e32e20b292 bash -c 'echo $CONNECT_PLUGIN_PATH'
shows : /usr/share/java,/usr/share/confluent-hub-components
[appuser@88db8385b575 ~]$ ls -la /usr/share/confluent-hub-components/
total 20
drwxr-xr-x 1 appuser appuser 4096 Mar 26 21:19 .
drwxr-xr-x 1 root root 4096 Feb 4 21:10 ..
drwxr-xr-x 6 appuser appuser 4096 Mar 26 18:00 confluentinc-kafka-connect-datagen
[appuser@88db8385b575 ~]$ ls -la /usr/share/confluent-hub-components/confluentinc-kafka-connect-datagen/
total 28
drwxr-xr-x 6 appuser appuser 4096 Mar 26 18:00 .
drwxr-xr-x 1 appuser appuser 4096 Mar 26 21:19 ..
drwxr-xr-x 2 appuser appuser 4096 Mar 26 18:00 assets
drwxr-xr-x 4 appuser appuser 4096 Mar 26 18:00 doc
drwxr-xr-x 2 appuser appuser 4096 Mar 26 18:00 etc
drwxr-xr-x 2 appuser appuser 4096 Mar 26 18:00 lib
-rw-r--r-- 1 appuser appuser 1380 Mar 26 18:00 manifest.json
Docker 日志：
docker logs 51e32e20b292 | grep "DatagenConnector"
"connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
"connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
I just added in the dockerfile and ran RUN confluent-hub install --no-prompt confluentinc/kafka-connect-datagen:0.4.0 inside the dockerfile. Nothing else. No error logs .
单独 运行 连接器，仅供连接 API 使用。请注意文档 https://github.com/confluentinc/kafka-connect-datagen#run-connector-in-docker-compose
中的 curl 示例
因此，公开端口 8083 并发出添加连接器的请求，并确保在 运行安装容器时添加所有相关环境变量
我正在尝试 运行 kafka-connect 容器内的 kafka datagen 连接器，我的 kafka 驻留在 AWS MSK 中使用：https://github.com/confluentinc/kafka-connect-datagen/blob/master/Dockerfile-confluenthub.
我正在使用 kafdrop 作为 kafka 代理 (MSK) 的 Web 浏览器。我没有看到 Kafka datagen 生成任何测试消息。 除了安装 kafka-datagen 连接器
之外，我还需要做其他配置吗此外，我如何在 confluentinc/kafka-connect 图像中检查创建了哪些主题以及是否使用了消息？
Docker文件看起来像：
ARG BASE_PREFIX=confluentinc
ARG CONNECT_IMAGE=cp-kafka-connect
FROM $BASE_PREFIX/$CONNECT_IMAGE:6.1.0
ENV CONNECT_PLUGIN_PATH="/usr/share/java,/usr/share/confluent-hub-components"
RUN confluent-hub install --no-prompt confluentinc/kafka-connect-datagen:0.4.0
docker exec 51e32e20b292 bash -c 'echo $CONNECT_PLUGIN_PATH'
shows : /usr/share/java,/usr/share/confluent-hub-components
[appuser@88db8385b575 ~]$ ls -la /usr/share/confluent-hub-components/
total 20
drwxr-xr-x 1 appuser appuser 4096 Mar 26 21:19 .
drwxr-xr-x 1 root root 4096 Feb 4 21:10 ..
drwxr-xr-x 6 appuser appuser 4096 Mar 26 18:00 confluentinc-kafka-connect-datagen
[appuser@88db8385b575 ~]$ ls -la /usr/share/confluent-hub-components/confluentinc-kafka-connect-datagen/
total 28
drwxr-xr-x 6 appuser appuser 4096 Mar 26 18:00 .
drwxr-xr-x 1 appuser appuser 4096 Mar 26 21:19 ..
drwxr-xr-x 2 appuser appuser 4096 Mar 26 18:00 assets
drwxr-xr-x 4 appuser appuser 4096 Mar 26 18:00 doc
drwxr-xr-x 2 appuser appuser 4096 Mar 26 18:00 etc
drwxr-xr-x 2 appuser appuser 4096 Mar 26 18:00 lib
-rw-r--r-- 1 appuser appuser 1380 Mar 26 18:00 manifest.json
Docker 日志：
docker logs 51e32e20b292 | grep "DatagenConnector"
"connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
"connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
I just added in the dockerfile and ran RUN confluent-hub install --no-prompt confluentinc/kafka-connect-datagen:0.4.0 inside the dockerfile. Nothing else. No error logs .
单独 运行 连接器，仅供连接 API 使用。请注意文档 https://github.com/confluentinc/kafka-connect-datagen#run-connector-in-docker-compose
中的 curl 示例因此，公开端口 8083 并发出添加连接器的请求，并确保在 运行安装容器时添加所有相关环境变量