gpt4 book ai didi

java - 检查系统是否连接到 Kafka

转载 作者:塔克拉玛干 更新时间:2023-11-03 05:04:54 25 4
gpt4 key购买 nike

我需要用 Java 编写一个冒烟测试来验证系统是否连接到 kafka,

有人知道吗?我找到了这篇文章:

How to check whether Kafka Server is running?

但是用 Java 代码做起来太复杂了,我不认为这是我应该使用的方向。

提前致谢。

最佳答案

我有同样的问题,我不想在没有任何答案的情况下留下这个问题。我读了很多关于如何检查连接的文章,我找到的大部分答案都是检查与 Zk 的连接,但我真的想直接检查与 Kafka 服务器的连接。

我所做的是创建一个简单的 KafkaConsumer 并使用 listTopics() 列出所有主题。如果连接成功,那么你会得到一些东西作为返回。否则,您将得到一个 TimeoutException

  def validateKafkaConnection(kafkaParams : mutable.Map[String, Object]) : Unit = {
val props = new Properties()
props.put("bootstrap.servers", kafkaParams.get("bootstrap.servers").get.toString)
props.put("group.id", kafkaParams.get("group.id").get.toString)
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
val simpleConsumer = new KafkaConsumer[String, String](props)
simpleConsumer.listTopics()
}

然后你可以把这个方法包裹在一个try-catch语句中来捕获异常。

关于java - 检查系统是否连接到 Kafka,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41016075/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com