如何在应用程序中获取Kafka的broker地址？

Question

我在项目中使用Java、Spring-Boot和Kafka。

@Autowired
private KafkaTemplate <String, MyRecord> kt;

private void produce ()
{
    MyRecord mr = new MyRecord ("abc");
    ProducerRecord <String, MyRecord> pr = new ProducerRecord <String, MyRecord> ("mytest", "test", mr);
    this.templ.send (pr);   // produce
}

@KafkaListener (topics = "mytest")
private void consume (ConsumerRecord <String, MyRecord> cr)
{   
    // consume
}

这是我的依赖。

<dependency>
      <groupId>org.springframework.kafka</groupId>
      <artifactId>spring-kafka</artifactId>
</dependency>

我将其配置为具有多个代理的集群。我如何找出我的应用程序连接到哪个经纪人？

Answer 1

这取决于您的应用程序配置，但您只需加载该值即可

@Value("spring.kafka.bootstrap-servers")
private String primary;