[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744877#comment-17744877
]
Tom Lee commented on KAFKA-10337:
-
Thanks for pushing this through [~erikvanoosten], nic
[
https://issues.apache.org/jira/browse/KAFKA-10518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302143#comment-17302143
]
Tom Lee commented on KAFKA-10518:
-
Attaching a contrived repro case. In case it's not ob
[
https://issues.apache.org/jira/browse/KAFKA-10518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Lee updated KAFKA-10518:
Attachment: kafka-slow-consumer-repro.tar.gz
> Consumer fetches could be inefficient when lags are unbalan
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169439#comment-17169439
]
Tom Lee commented on KAFKA-10337:
-
Opened [https://github.com/apache/kafka/pull/9111] to
Tom Lee created KAFKA-10337:
---
Summary: Wait for pending async commits in commitSync() even if no
offsets are specified
Key: KAFKA-10337
URL: https://issues.apache.org/jira/browse/KAFKA-10337
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959918#comment-16959918
]
Tom Lee commented on KAFKA-8950:
Yeah sounds very similar. If 2.3.1 doesn't help when it
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959813#comment-16959813
]
Tom Lee commented on KAFKA-8950:
This specific bug was new in 2.3.0, yep. IIRC the map th
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951169#comment-16951169
]
Tom Lee commented on KAFKA-8950:
Sounds good to me [~rsivaram], agree the fix seems trivi
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951140#comment-16951140
]
Tom Lee commented on KAFKA-8950:
[~rsivaram] hm new flag? Couldn't we just move the
node
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951100#comment-16951100
]
Tom Lee commented on KAFKA-8950:
Oh wait, the RequestFutureCompletionHandlers can be invo
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951096#comment-16951096
]
Tom Lee commented on KAFKA-8950:
[~rsivaram] plaintext transport here too. Not sure we co
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950707#comment-16950707
]
Tom Lee commented on KAFKA-8950:
Ah wait I misunderstood what you said above: so not trou
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950702#comment-16950702
]
Tom Lee edited comment on KAFKA-8950 at 10/14/19 4:09 AM:
--
Hm no
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950702#comment-16950702
]
Tom Lee edited comment on KAFKA-8950 at 10/14/19 4:08 AM:
--
Hm no
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950702#comment-16950702
]
Tom Lee commented on KAFKA-8950:
Hm not sure I see what you mean. I think you're right th
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950644#comment-16950644
]
Tom Lee commented on KAFKA-8950:
Believe we're also running into this. High throughput to
16 matches
Mail list logo