confluentinc
diff --git a/‎src/rdkafka_broker.c‎
Lines changed: 1 addition & 1 deletion b/‎src/rdkafka_broker.c‎
Lines changed: 1 addition & 1 deletion
@@ -3612,7 +3612,7 @@ rd_kafka_broker_op_serve(rd_kafka_broker_t *rkb, rd_kafka_op_t *rko) {
                         rd_kafka_op_reply(rko,
                                           RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS);
                 } else {
-                        rd_kafka_broker_share_fetch(rkb, rko, rd_clock());
+                        rd_kafka_broker_share_rpc(rkb, rko, rd_clock());
                 }
 
                 // if (!rko->rko_u.share_fetch.should_fetch) {
Original file line number	Diff line number	Diff line change
`@@ -3612,7 +3612,7 @@ rd_kafka_broker_op_serve(rd_kafka_broker_t rkb, rd_kafka_op_t rko) {`
`3612`	`3612`	`rd_kafka_op_reply(rko,`
`3613`	`3613`	`RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS);`
`3614`	`3614`	`} else {`
`3615`		`- rd_kafka_broker_share_fetch(rkb, rko, rd_clock());`
	`3615`	`+ rd_kafka_broker_share_rpc(rkb, rko, rd_clock());`
`3616`	`3616`	`}`
`3617`	`3617`
`3618`	`3618`	`// if (!rko->rko_u.share_fetch.should_fetch) {`