Martyn Ye
Martyn Ye
This should be race condition after checking the code, I am working on the fix
@colinkuo @rkolesnev from my perspective, the most possible guess is the offset from `TopicPartition` is 0. Since for both bitSet and Runlength encoding, if there is no incompleteoffsets, you should...
@rbokade-rbk , I think the partitions sub is paused according to the log and that is why you could not get any new records even you assigned the partition. And...
@netroute-js @rbokade-rbk please provide a trace level log when this issue happens, I will take a look.
@rbokade-rbk the log is too short, I checked again. I don't have enough information. My fix is introduced in 0.5.2.7. So supposedly you should not have the issue. Because the...
@netroute-js please set TRACE level logging limited to the `io.confluent` package to avoid too many other irrelevant logging.
@netroute-js, I was super busy as you know I am not Confluent guys so I have my work to do.. Anyway, I took some time to look at the new...
@netroute-js @rbokade-rbk I draft a pr for possible fix. I will ask confluent guys to review https://github.com/confluentinc/parallel-consumer/pull/882
@netroute-js please ask for help in Slack channel since I am not member of Confluent so I don't have permission to release new version.
@netroute-js @rbokade-rbk @rbokade11 The new version has released, please integrate and let me know if still having issue