Reset buffer corrid on connection close to honour ApiVers and Sasl re…

…quest priorities (@xzxxzx401, #2666)
confluentinc · Feb 5, 2020 · 76e3592 · 76e3592
1 parent 81bed42
commit 76e3592
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/rdkafka_buf.c b/src/rdkafka_buf.c
@@ -274,8 +274,9 @@ void rd_kafka_bufq_connection_reset (rd_kafka_broker_t *rkb,
 					      NULL, rkbuf);
 			break;
                 default:
-                        /* Reset buffer send position */
+                        /* Reset buffer send position and corrid */
                         rd_slice_seek(&rkbuf->rkbuf_reader, 0);
+                        rkbuf->rkbuf_corrid = 0;
                         /* Reset timeout */
                         rd_kafka_buf_calc_timeout(rkb->rkb_rk, rkbuf, now);
                         break;