apache-kafka - Haproxy 背后的 Spring Cloud Stream Kafka Broker

Question

我们有一个带有 apache kafka binder 的 Spring 云流应用程序。有人可以帮助提供代码片段如何在 haproxy 后面使用 kafka 代理和 zookeeper，这不仅是出于负载平衡的原因，也是为了帮助进行蓝绿色部署。我们只有一个 kafka 可以被两个蓝绿色组件读取。我们希望限制从 kafka 读取的绿色组件，直到它被交换成为活动端。