jatindersthind

Results 5 comments of jatindersthind

Thanks for your reply. I haven't triggered the close. This gets triggered automatically. Looks like it is timing out while waiting for commit response from kafka. We wanted to use...

> Could you elaborate on your memory concerns? We used Synchronous Commit mode, assuming that Asynchronous mode has to keep info for pending offsets in memory. So it might use...

> What version? 0.5.2.1 @astubbs Also we see multiple different types of errors due to which parallelconsumer shutdown happens, but our java process still keeps running. Is there any way...

> Please update to the latest version, then try again? Sure will try to update to 0.5.2.3 Also will try working on isClosedOrFailed periodic checks

> We're also about to release a metrics package which might be relevant - so stay tuned on: sure > Yes, you can periodically call the `isClosedOrFailed` method. Just need...