K8s 上广告的 kafka 连接休息侦听器

Question

我正在努力以分布式模式在 Kubernetes (DockerEE) 上设置 Kafka Connect。
目前，我在三个相应的 k8s-pod 上有一个由三个工作人员组成的集群。
我面临的问题是我的员工之间很难相互沟通（至少我是这么认为的）。

当我尝试启动连接器时，我得到：

{"error_code":409,"message":"Cannot complete request because of a conflicting operation (e.g. worker rebalance)"}

作为回应。令人困惑的是我并不总是得到这个错误响应。有时它会起作用并且连接器会按预期启动。

从我读到的内容来看，这可能归结为我配置为 CONNECT_REST_ADVERTISED_HOST_NAME 的内容。

在 k8s 中运行时作为广告地址放置的正确值是多少？

BR

Answer 1

经过一番谷歌搜索后，我找到了一种将 pod-ip 动态分配为 CONNECT_REST_ADVERTISED_HOST_NAME 的方法。

- name: CONNECT_REST_ADVERTISED_HOST_NAME
  valueFrom:
    fieldRef:
      fieldPath: status.podIP

这样一来，问题似乎就消失了。