[
https://issues.apache.org/jira/browse/KAFKA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14133506#comment-14133506
]
Neha Narkhede commented on KAFKA-1612:
--
[~gian] The current API was designed to
[
https://issues.apache.org/jira/browse/KAFKA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14114320#comment-14114320
]
Gian Merlino commented on KAFKA-1612:
-
I am currently working around this by setting
[
https://issues.apache.org/jira/browse/KAFKA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14110100#comment-14110100
]
Gwen Shapira commented on KAFKA-1612:
-
You should be able to use the commitOffsets()