Apache Kafka:获取相关id为0的主题元数据

Question

我使用以下代码向我的 Kafka 发送了一条消息：

 def getHealthSink(kafkaHosts: String, zkHosts: String) = {
    val kafkaHealth: Subscriber[String] = kafka.publish(ProducerProperties(
      brokerList = kafkaHosts,
      topic = "health_check",
      encoder = new StringEncoder()
    ))
    Sink.fromSubscriber(kafkaHealth).runWith(Source.single("test"))
  }
  val kafkaHealth = getHealthSink(kafkaHosts, zkHosts)

我收到了以下错误消息：

错误kafka.utils。Utils$fetching topic metadata for topics[Set（health_check）]from broker[ArrayBuffer（id:0，host:****，port:9092）]failed kafka.common（从代理[Array缓冲区（id:0，主机：****，端口：9092））]获取主题[Set（健康检查）]。KafkaException:从代理[ArrayBuffer（id:0，host:****，port:9092）]获取主题[Set（health_check）]的主题元数据失败

你知道问题出在哪里吗？

Answer 1

错误消息令人难以置信地不清楚，但基本上“获取主题元数据”是制作人做的第一件事，这意味着这是它第一次与Kafka建立连接的地方。

很有可能您尝试连接的代理已关闭，或者存在其他连接问题（端口、防火墙、dns等）。

在不相关的新闻中：您似乎正在使用旧的和已弃用的Scala生成器。我们建议迁移到新的Java生成器（org.apache.kafka.clients.KafkaProducer）