k8s上的广告kafka connect rest侦听器

3ks5zfa0 于 2021-06-05 发布在 Kafka

关注(0)|答案(1)|浏览(350)

我正在努力设置Kafka连接在kubernetes（dockeree）在分布式模式。
目前，我有一个集群的三个工人在三个相应的k8s吊舱。
我面临的问题是，我的员工们很难相互沟通（至少我相信这一点）。
当我尝试启动连接器时，我得到：

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

作为回应。令人费解的是，我并不总是得到这种错误的React。有时它工作，连接器按预期启动。
据我所知，这可能归结为我所配置的连接\休息\广告\主机名。
在k8s中运行时，作为播发地址的正确值是什么？
比尔

1条答案

在谷歌搜索之后，我找到了一种方法，可以动态地将pod ip分配为connect\u rest\u播发的\u host\u name。

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

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