Spring-Kafka：如何在Producer Kafka中插入application.yml主题

Question

//some code..
@Component
public class KafkaProducer {
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendDeadLetter(String message) {
        kafkaTemplate.send("myDeadLetter", message);
    }
}

@KafkaListener(topics = "${spring.kafka.topic.name}")

我如何通过可能从application.yml中插入“+死信”来设置相同的Kafka主题？我试过这样一件事：

@Component
@KafkaListener(topics = "${spring.kafka.topic.name}"+"_deadLetter")
public class KafkaProducer {
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendDeadLetter(String message) {
        kafkaTemplate.send("messageTopic_deadLetter", message);
    }
}

但它给我创造了两个同名的不同主题。我正在等待一些建议，谢谢你的帮助！

Answer 1

Kafka监听器接受常量作为主题名，我们不能在这里修改主题名。

理想情况下，对于实际主题和死信主题，最好使用单独的方法（Kafka侦听器），在YAML中定义两个不同的属性来保存两个主题名。

@KafkaListener(topics = "${spring.kafka.topic.name}")
public void listen(......){

}

@KafkaListener(topics = "${spring.kafka.deadletter.topic.name}")
public void listenDlt(......){

}

在发送（...）中引用主题名称从yml或属性文件

@Component
@KafkaListener(topics = "${spring.kafka.deadletter.topic.name}")
public class KafkaProducer {

    @Value("${spring.kafka.deadletter.topic.name}")
    private String DLT_TOPIC_NAME;

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendDeadLetter(String message) {
        kafkaTemplate.send(DLT_TOPIC_NAME, message);
    }
}