У нас есть приложение Spring Cloud Stream с Apache Kafka Binder.Может кто-нибудь помочь с фрагментами кода, как использовать kafka broker и zookeeper за haproxy не только по причине балансировки нагрузки, но и для помощи в развертывании сине-зеленого. У нас есть только одна kafka, которая читается обоими сине-зелеными компонентами.Мы хотим ограничить чтение зеленого компонента из kafka, пока он не поменяется местами, чтобы стать активной стороной.