在同一消费阶层中消费多个Kafka主题

Question

我有一个spring boot项目，我是spring-kafka来连接底层的kafka事件枢纽。

我不得不在同一节消费者课上听2个不同的话题。我有两种方法可以这样做。

一个是要有两个这样的Kafka听众：

 @KafkaListener(topics = "topic1")
public void consumeTopic1(String message) throws Exception {  
   //do something
  }

 @KafkaListener(topics = "topic2")
public void consumeTopic2(String message) throws Exception {  
   //do something
  }

另一种方法是在同一个kafkaListener中有两个主题，如下所示

 @KafkaListener(topics = {"topic1", "topic2"})
public void consumeTopics(String message) throws Exception {  
   //do something
  }

===================edit===============application.yml中的Kafka属性如下所示：

 kafka:
    properties:
      topics:
        topic1: topic1
        topic2: topic2
    bootstrap-servers: server1,server2
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
      retries: 4
    consumer:
      group-id: mygroupid
      auto-offset-reset: latest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

Answer 1

>

创建多个主题的目的是在多个
内核/进程/线程之间传播数据，并
随后传播数据的处理。

即使这样，您也可以从多个主题的单个使用者开始，直到在队列中处理事件时观察到延迟。然后你就可以把它们分开。