From 4614e1416244e1540db6b9525cd317afd359582e Mon Sep 17 00:00:00 2001 From: Magnus Edenhill Date: Tue, 28 Jan 2014 20:23:16 +0700 Subject: [PATCH] Emit ..ERR__ALL_BROKERS_DOWN error after specific broker error (issue #64) --- rdkafka_broker.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/rdkafka_broker.c b/rdkafka_broker.c index 940b52be46..34a8874599 100644 --- a/rdkafka_broker.c +++ b/rdkafka_broker.c @@ -317,8 +317,6 @@ static void rd_kafka_broker_fail (rd_kafka_broker_t *rkb, rkb->rkb_err.err = errno_save; - rd_kafka_broker_set_state(rkb, RD_KAFKA_BROKER_STATE_DOWN); - if (rkb->rkb_s != -1) { close(rkb->rkb_s); rkb->rkb_s = -1; @@ -357,6 +355,9 @@ static void rd_kafka_broker_fail (rd_kafka_broker_t *rkb, "%s", rkb->rkb_err.msg); } + /* Set broker state */ + rd_kafka_broker_set_state(rkb, RD_KAFKA_BROKER_STATE_DOWN); + /* * Purge all buffers * (put on a temporary queue since bufs may be requeued)