apache-kafka - 两个 Kafa 消费者和一个生产者

Question

我在来自一个生产者的两个微服务中定义了两个 kafka 消费者，定义了不同的组 id。其中一个微服务不使用来自生产者的消息

---

@Component
@ConditionalOnProperty(value = "XXX", havingValue = "true")
public class EventListener {


  @KafkaListener(id = "XX", topics = "#{'${topic'}")
  public void consumeMessageEvent(Event messageEvent, ConsumerRecord<String, ?> record) {

  }

  }

标签： apache-kafkakafka-consumer-apikafka-producer-api