apache-kafka-streams - Kafka Stream Listener 中的多个主题

Question

我只想为我的消费者类配置另一个 kafka 主题，目前只有一个主题。

@Slf4j

@零件

@EnableBinding(Sink.class)

@CrossOrigin(origins = "*", maxAge= 3600)

公共类 EBIConsumer 扩展 EDIKafkaConstants{

@Autowired

EDIKafkaService supplierMdmService;

**@StreamListener(Sink.INPUT)**
public void receive(String payload) {
    log.info("----------------");
    log.info("input email topic  {}", payload);
    log.info("----------------");
    long start = System.currentTimeMillis();
    supplierMdmService.processPayload(payload);
    long end = System.currentTimeMillis();
    log.info("processed in {} milli seconds", end - start, MESSAGE_INSERT_STATUS);
}

应用程序.yml

溪流：

  bindings:

    input:

      content-type: application/json

      destination: PINE_PMC_PEARL_EMAIL

      group: CCE_PMC_EMAIL_DIT

如何在同一个类中配置另一个 kafka 主题，在 sink 接口中只有一个输入通道可用。如何使用流侦听器设置另一个主题。

提前致谢！

标签： apache-kafka-streams