Description
This will include adding functionality to the commit()/commitAsync()/committed() APIs.
Attachments
Issue Links
- duplicates
-
KAFKA-1760 Implement new consumer client
- Resolved
- is blocked by
-
KAFKA-1330 Implement subscribe(TopicPartition...partitions) and pool(timeout) in the consumer
- Resolved