用多个Kafka消费者集群配置spring引导应用程序，每个集群都有不同的SSL配置？

Question

我有一个单一的spring引导应用程序，它需要使用来自两个不同的Kafka集群的主题的数据，这些主题具有独立的SSL信任(keystore和trusstore文件和位置)。

是否可以在application.yml/properties文件中对其进行配置？使用卡夫卡/弹簧云流绑定/绑定？

任何线索/帮助理解如何通过yaml/属性文件如果是或如果不可能？

我试图在spring.cloud.stream.bindings.consumer下配置第二个集群属性，在spring.kafka.consumer下配置第一个集群属性，正如我在社区中看到的那样，它只配置了第一个集群属性，而不是同时配置了第一个集群属性。

Answer 1

是的，您可以使用@KafkaListener注释定义多个Kafka。

@Service
public class KafKaConsumerService 
{
  private final Logger logger 
    = LoggerFactory.getLogger(KafKaConsumerService.class);
   
  @KafkaListener(topics = "${general.topic.name}", 
      groupId = "${general.topic.group.id}")
  public void consume(String message) {
    logger.info(String.format("Message recieved -> %s", message));
  }
 
  @KafkaListener(topics = "${user.topic.name}", 
      groupId = "${user.topic.group.id}", 
      containerFactory = "userKafkaListenerContainerFactory")
  public void consume(User user) {
    logger.info(String.format("User created -> %s", user));
  }
}

多重卡夫卡消费者