ListOffsetsRequest should only be sent to the leader replica

confluentinc · Feb 12, 2024 · dfb9e3e · dfb9e3e
1 parent 6d88efd
commit dfb9e3e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/rdkafka_partition.c b/src/rdkafka_partition.c
@@ -1541,7 +1541,7 @@ void rd_kafka_toppar_offset_request(rd_kafka_toppar_t *rktp,
         rd_kafka_assert(NULL,
                         thrd_is_current(rktp->rktp_rkt->rkt_rk->rk_thread));
 
-        rkb = rktp->rktp_broker;
+        rkb = rktp->rktp_leader;
 
         if (!backoff_ms && (!rkb || rkb->rkb_source == RD_KAFKA_INTERNAL))
                 backoff_ms = 500;