【发布时间】:2023-01-19 01:37:49
【问题描述】:
我看到人们复制代码来为每个集群配置 kafka :(
真的有必要每次都给Consumer Factory和Producer Factory配置不同的设置吗?并且不要以任何方式使用 Spring Boot Kafka 启动器?
【问题讨论】:
标签: spring-kafka
我看到人们复制代码来为每个集群配置 kafka :(
真的有必要每次都给Consumer Factory和Producer Factory配置不同的设置吗?并且不要以任何方式使用 Spring Boot Kafka 启动器?
【问题讨论】:
标签: spring-kafka
Spring Boot 自动配置是常见微服务用例的约定:一回事,但简单明了。
您要问的超出了 Spring Boot 范围:属性配置仅适用于一个 ConsumerFactory 和一个 ProducerFactory。只要您需要连接到不同的集群,您就只能靠自己了。拥有自定义 ConsumerFactory bean 将导致 Spring Boot 自动配置后退。
您可能可以查看带有自己提供的一组属性的子 ApplicationContext 配置。但是,如果没有 Spring Boot 而只有一个普通的 Apache Kafka 客户端,那么为每个集群自定义配置会更容易吗?
我不知道 Apache Kafka 是否有一些联邦解决方案。但这仍然超出了 Apache Kafka 和 Spring Boot 范围的 Spring。
【讨论】: