_fetch_metadata(): all brokers failed in fetch topic metadata,

[kfrtiamo]

local producer = require "resty.kafka.producer"

local brokers = { { host = "10.154.46.66", port = 9092 } } local producer_config = { ["bootstrap.servers"] = "10.154.46.66:9092", ["sasl.username"] = "xxxxx", ["sasl.password"] = "xxxxxxxxg", ["sasl.mechanism"] = "PLAIN", ["security.protocol"] = "SASL_PLAINTEXT" }

local p, err = producer:new(producer_config)

if not p then ngx.log(ngx.ERR, "failed to create kafka producer: ", err) ngx.say(ngx.ERR, "failed to create kafka producer: ", err) return else ngx.say(ngx.ERR, "create kafka producer: ", err) end

一直报 2024/02/20 14:50:30 [error] 27622#0: 15 [lua] client.lua:151: _fetch_metadata(): all brokers failed in fetch topic metadata, client: 10.139.152.93, server: localhost, request: "POST /isales-open-agc-transporter/buryingPoint/push HTTP/1.1", host: "10.154.44.214" 2024/02/20 14:50:30 [error] 27622#0: 15 [lua] buryingPointSend.lua:124: not 1 failed to send message: not found topic, client: 10.139.152.93, server: localhost, request: "POST /isales-open-agc-transporter/buryingPoint/push HTTP/1.1", host: "10.154.44.214" 什么问题导致的呢