在 k8s 上使用 Strimzi 部署远程调试自定义 Kafka 连接器

Question

我想远程调试我的自定义连接器，它是我在 Kubernetes 上部署的 Strimzi Kafka 操作员的一部分。

本地（例如使用 docker 图像），这可以通过添加 JAVA_TOOL_OPTIONS 作为具有此值的环境参数来完成：-agentlib:jdwp=transport=dt_socket,address=*:5005,server=y,suspend=n 并在 [=22= 中公开] 运行命令5005端口。

然而，在 k8s 中，我还应该将端口 5005 添加到部署中，这样我就可以使用节点端口（或其他东西）来在集群外部公开部署的调试端口（5005）（所以我的 IDE 可以附加到它）。

但是，我无法更改已创建的 Kafka 连接部署的公开端口（毕竟，您只能应用 KafkaConnect 自定义资源并且部署是作为其中的一部分创建的）。

是否有远程调试此连接器的解决方法？还是 Strimzi 有一些配置值？

Answer 1

一旦停止 strimzi 协调，就可以像通常进行远程调试一样完成。

完成后，从 Kafka Connect 资源中删除 strimzi.io/pause-reconciliation: "true"，这会将集群恢复到原始状态

1. 调整Kafka Connect资源 1.1 为Kafka Connect资源添加一个新的环境变量
   - 姓名：JAVA_TOOL_OPTIONS
   值：-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=*:5005
   1.2 应用更改并等待部署结束
   1.3 添加新注解
   strimzi.io/pause-reconciliation: "真"
   1.4 应用更改
2. 更新 Kafka Connect 部署并添加新端口（匹配 JAVA_TOOL_OPTIONS 中的端口）
   • 名称：调试
     容器端口：5005
     协议：TCP
3. 创建一个 NodePort 服务，将 Kafka Connect 的端口 5005 映射到某个节点端口（比如 35005）
4. 添加远程调试配置 3.1 Host应该是k8s节点之一
   3.2 端口与您在 NodePort 中定义的相同（在我们的示例中为 35005）
   3.3 申请

现在您可以使用创建的配置进行调试。