bug fix: request NULL, force_racks in MetadataReq

confluentinc · Jun 14, 2023 · 7c15746 · 7c15746
1 parent 88707a0
commit 7c15746
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/examples/describe_consumer_groups.c b/examples/describe_consumer_groups.c
@@ -375,10 +375,6 @@ int main(int argc, char **argv) {
          * Create Kafka client configuration place-holder
          */
         conf = rd_kafka_conf_new();
-        conf_set(conf, "sasl.username", "broker");
-        conf_set(conf, "sasl.password", "broker");
-        conf_set(conf, "sasl.mechanism", "SCRAM-SHA-256");
-        conf_set(conf, "security.protocol", "SASL_PLAINTEXT");
 
         /*
          * Parse common options

diff --git a/src/rdkafka_metadata.c b/src/rdkafka_metadata.c
@@ -493,7 +493,7 @@ rd_kafka_parse_Metadata(rd_kafka_broker_t *rkb,
         /* If force_racks is true, the outptr mdip has to contain the partition
          * to rack map. */
         rd_bool_t force_rack_computation =
-            request->rkbuf_u.Metadata.force_racks;
+            request ? request->rkbuf_u.Metadata.force_racks : rd_false;
         rd_bool_t compute_racks = has_client_rack || force_rack_computation;
 
         /* Ignore metadata updates when terminating */