We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 018d150 commit 372525cCopy full SHA for 372525c
src/rdkafka_metadata.c
@@ -528,7 +528,7 @@ static void rd_kafka_metadata_decommission_unavailable_brokers(
528
* `rd_kafka_broker_decommission` is called below. */
529
if (rd_list_find(&rk->wait_decommissioned_brokers, rkb,
530
rd_list_cmp_ptr) != NULL)
531
- break;
+ continue;
532
533
rd_list_add(&brokers_to_decommission, rkb);
534
}
0 commit comments