为两个独立的集群配置 Spring Kafka

Question

是否可以将 Kafka 配置为在单个 spring 启动应用程序中使用两个独立的集群？

用例： 我有两个带有副本 + zookeeper 的集群：

• 集群 #1 bootstrap-服务器：server1.example.com,server2.example.com,server3.example.com
• 集群 #2 bootstrap-服务器：target-server1.example.com,target-server2.example.com,target-server3.example.com

我需要使用来自 Cluster #1 的消息，然后根据该数据进行一些计算并将结果生成到 Cluster #2 主题。有没有办法在单个 Spring 应用程序中配置 Kafka 来处理这种方法？

Answer 1

是的，但是如果你想同时消费和生产，你必须手动配置消费者和生产者工厂@Bean等

启动只能从属性中自动配置每一项。

但是如果您只是简单地从一个集群消费并生产到另一个集群，它可以通过属性来完成。

使用

spring.kafka.producer.bootstrap-servers=...
...
spring.kafka.consumer.bootstrap-servers=...

这些将覆盖通用属性。