首页 > 解决方案 > 在 Kubernetes/OpenShift 中运行 Kafka Connect Workers 而不通过 REST API 发布配置?

问题描述

我想在 OpenShift 上运行 Kafka 连接工作人员。我想使用 OpenShift 来(自动)横向扩展。但是,我不清楚如何传递连接器配置,如果它通常是在启动后通过 REST 调用手动提供给特定工作人员的。

因此,问题是是否有可能在没有 REST 调用的情况下在启动时向工作人员提供完整的连接器规范。

标签: kubernetesopenshiftapache-kafka-connect

解决方案


在没有 REST 调用的启动时间

不它不是。请参阅我为它创建的问题

不过,您只需使用 REST 加载一次连接器配置。工作人员配置完全由环境变量驱动,并且扩展工作人员不需要发布新的连接器配置来扩展它们,除非您确实想增加tasks.max例如。但是无论如何,您都可以将其作为 Kafka 分区的数量开始,这就是您对 Connect 的限制,即使只有一个工作人员也是如此。


推荐阅读