Spring-Kafka:如何从application.yml传递kafka主题

Question

我在 Spring Kafka 中有一个小项目我希望我可以从 application.yml 传递我的 kafka 主题并避免硬编码问题。目前我有这种情况:

public class KafkaConsumer {
    @Autowired
    private UserRepository userRepository;


    @KafkaListener(topics = "myTopic")
    public void listen(@Validate UserDto userDto) {

        User user= new User(userDto);
        userRepository.save(userDto.getAge(), user);
    }
}

此时我有静态kafka主题(是一个字符串)是否可以将它放在application.yml中并从那里读取？感谢大家的帮助

Answer 1

您可以在 application.yml 中发布您的主题:

kafka:
  template:
    default-topic: "MyTopic"

在你的 KafkaListerner 中:

@KafkaListener(topics = "#{'${spring.kafka.template.default-topic}'}")

所以应该解决“属性值”不能取动态值的问题

这对我有用。