Details
-
Wish
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
Description
Currently, in KafkaConsumer, various methods blocks due to a remote callback. It would be nice if we also added asynchronous version of these methods, like what was done with commitAsync() which uses a OffsetCommitCallback as an input argument.