Кафка ошибка: не найден брокер

Question

У меня есть конфиг nginx kafka lua:

local client = require "resty.kafka.client"
local producer = require "resty.kafka.producer"

local broker_list = {
    { host = "192.168.10.12", port = 9092 },
    { host = "192.168.10.13", port = 9092 },
    { host = "192.168.10.14", port = 9092 }
}

data = json.encode(args)
local ok, err = ngx.print(data)
local message = json.encode(data);

local bp = producer:new(broker_list, { producer_type = "async" })
local ok, err = bp:send("box",key, message)

Моя проблема:

1. Когда я останавливаю kafka node1 и отправляю сообщение с URL-адресом сообщения производителя http://xxxx:8081/box но не отправка сообщения в тему и ошибка журнала отладки nginx ниже

   2019/04/15 00:25:53 [ошибка] 15931 # 15931: * 383566 [lua] Manufacturer.lua:258: буферизованные сообщения отправляются в кафку. Ошибка: не найден, посредник, повторяемый: истина, тема: поле, идентификатор_раздела: 6, длина: 1, контекст: ngx.timer

2. ПослеЯ перезагружаю nginx, затем отправляю сообщение в тему "box" => результат Ok => Кластер списка брокеров kafka не в порядке или не стабилен?