Hi,
thanks for sharing this and getting feedback. Sorry I am probably missing
something basic, but I'm not sure how a multi-threaded consumer would
work. I can imagine its either:
a) I just have one thread poll kafka. If I want to process msgs in
multiple threads, than I deal w/ that after pol
[
https://issues.apache.org/jira/browse/KAFKA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13833068#comment-13833068
]
Imran Rashid commented on KAFKA-1144:
-
Hi Jun,
yes, that will do the trick. I t
[
https://issues.apache.org/jira/browse/KAFKA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Imran Rashid updated KAFKA-1144:
Attachment: 0003-dont-do-conditional-update-check-if-the-path-doesnt-.patch
just discovered a
[
https://issues.apache.org/jira/browse/KAFKA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13832019#comment-13832019
]
Imran Rashid commented on KAFKA-1144:
-
yes, that addition to the commit api woul
[
https://issues.apache.org/jira/browse/KAFKA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13831658#comment-13831658
]
Imran Rashid commented on KAFKA-1144:
-
Thanks for quick response, Jun.
(1
[
https://issues.apache.org/jira/browse/KAFKA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Imran Rashid updated KAFKA-1144:
Attachment: 0002-add-protection-against-backward-commits.patch
0001-allow
[
https://issues.apache.org/jira/browse/KAFKA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Imran Rashid updated KAFKA-1144:
Affects Version/s: 0.8
Status: Patch Available (was: Open)
> commitOffsets can
Imran Rashid created KAFKA-1144:
---
Summary: commitOffsets can be passed the offsets to commit
Key: KAFKA-1144
URL: https://issues.apache.org/jira/browse/KAFKA-1144
Project: Kafka
Issue Type
