【发布时间】:2021-06-26 09:34:21
【问题描述】:
我们使用@EmbeddedKafka,在application-test.yml 中我们有
kafka:
confluentBootstrapAddress: ${spring.embedded.kafka.brokers}
我可以看到confluentBootstrapAddress 是null。
但是,如果在调试模式下我会检查这个
this.resolveEmbeddedValue("${spring.embedded.kafka.brokers}") = "127.0.0.1:51020"
然后我可以看到该值存在,并且嵌入式 Kafka 确实已启动。
可能是什么问题?评估 application.yml 与启动嵌入式代理之间的生命周期/时刻不匹配?
【问题讨论】:
标签: java spring apache-kafka spring-kafka spring-kafka-test