Ken Dubuc
Ken Dubuc
I recently encountered the same issue. I traced it down to the fact that: 1. `rd_kafka_toppar_fetch_stop` calls `rd_kafka_q_fwd_set(rktp->rktp_fetchq, NULL);`, which, at least in our application, disconnects the `rktp_fetchq` from anything...
Yes, we're working off a fork of v2.1.0, which has https://github.com/confluentinc/librdkafka/pull/4187.
I've attached debug logs illustrating the issue in our reproduction. [confluentinc-librdkafka-4362.txt](https://github.com/confluentinc/librdkafka/files/12232118/confluentinc-librdkafka-4362.txt)