Emit ..ERR__ALL_BROKERS_DOWN error after specific broker error (issue #…

…64)
confluentinc · Jan 28, 2014 · 4614e14 · 4614e14
1 parent 7e0f492
commit 4614e14
Showing 1 changed file with 3 additions and 2 deletions.
diff --git 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)