Ken Dubuc

Results 3 comments of 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)