Xiaodong Huo
Xiaodong Huo
I think I came across the same issue with Sarama 1.31.0 kafka 1.1.0 with golang 1.17.5 And below is my extracted goroutine stack ``` goroutine profile: total 334 45 @...
Hi, I made some code modification at rdkafka tag v0.11.6. The change is based on rd_kafka_offsets_for_times API's implementation. ```diff diff --git a/src/rdkafka.c b/src/rdkafka.c index 86d347f8..797ee937 100644 --- a/src/rdkafka.c +++ b/src/rdkafka.c...
@edenhill The code change is tiny, could you help to take a look and consider about merging into master branch? Thanks!