自托管EKS上Confluent集群安装Kafka Connect ZeeBee插件遇权限问题求助

临时调试解决方案 #

1. 切换root身份执行操作 #

默认Confluent Connect容器以非root用户运行，先通过sudo切换到root：

kubectl exec -it connect-0 -- sudo -i

之后再执行以下操作：

• 复制Zeebe连接器jar包到组件目录：

cp /tmp/kafka-connect-zeebee.jar /usr/share/confluent-hub-components/

• 用confluent-hub安装连接器：

confluent-hub install camunda/kafka-connect-zeebe:latest --component-dir /usr/share/confluent-hub-components --no-prompt

2. 修改组件目录权限 #

先给目标目录开放权限（需root执行）：

kubectl exec -it connect-0 -- sudo chmod -R 777 /usr/share/confluent-hub-components

之后即可正常执行复制或安装命令。

生产环境规范解决方案 #

1. 构建自定义Connect镜像 #

在Dockerfile中预先安装Zeebe连接器，避免运行时权限问题：

FROM confluentinc/cp-kafka-connect:latest

USER root
RUN confluent-hub install camunda/kafka-connect-zeebe:latest --component-dir /usr/share/confluent-hub-components --no-prompt
USER appuser

构建镜像并推送到私有仓库后，修改EKS中Connect Deployment的镜像地址为自定义镜像。

2. 用Init容器调整目录权限 #

在Connect的Deployment配置中添加Init容器，提前修正目录权限：

initContainers:
- name: fix-components-permission
  image: busybox:latest
  command: ["sh", "-c", "chmod -R 777 /usr/share/confluent-hub-components"]
  volumeMounts:
  - name: connect-components-volume
    mountPath: /usr/share/confluent-hub-components

确保对应volume已正确挂载到主容器的相同路径。

3. 调整容器运行用户（不推荐生产环境） #

修改Deployment的securityContext，让容器以root用户运行：

securityContext:
  runAsUser: 0
  runAsGroup: 0

内容的提问来源于stack exchange，提问作者Socrates Hlapolosa