[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744877#comment-17744877
]
Tom Lee commented on KAFKA-10337:
-
Thanks for pushing this through [~erikvanoosten], nice to see this
[
https://issues.apache.org/jira/browse/KAFKA-10518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302143#comment-17302143
]
Tom Lee commented on KAFKA-10518:
-
Attaching a contrived repro case. In case it's not obvious: in the
[
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
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169439#comment-17169439
]
Tom Lee commented on KAFKA-10337:
-
Opened [https://github.com/apache/kafka/pull/9111] to address this
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=16959918#comment-16959918
]
Tom Lee commented on KAFKA-8950:
Yeah sounds very similar. If 2.3.1 doesn't help when it ships, I'd open
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959813#comment-16959813
]
Tom Lee commented on KAFKA-8950:
This specific bug was new in 2.3.0, yep. IIRC the map that would get
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951169#comment-16951169
]
Tom Lee commented on KAFKA-8950:
Sounds good to me [~rsivaram], agree the fix seems trivial. To be clear,
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951140#comment-16951140
]
Tom Lee commented on KAFKA-8950:
[~rsivaram] hm new flag? Couldn't we just move the
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951100#comment-16951100
]
Tom Lee commented on KAFKA-8950:
Oh wait, the RequestFutureCompletionHandlers can be invoked by the
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951096#comment-16951096
]
Tom Lee commented on KAFKA-8950:
[~rsivaram] plaintext transport here too. Not sure we could provide the
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950707#comment-16950707
]
Tom Lee commented on KAFKA-8950:
Ah wait I misunderstood what you said above: so not trouble with the
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950702#comment-16950702
]
Tom Lee edited comment on KAFKA-8950 at 10/14/19 4:09 AM:
--
Hm not sure I see
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950702#comment-16950702
]
Tom Lee edited comment on KAFKA-8950 at 10/14/19 4:08 AM:
--
Hm not sure I see
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950702#comment-16950702
]
Tom Lee commented on KAFKA-8950:
Hm not sure I see what you mean. I think you're right that
[
https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950644#comment-16950644
]
Tom Lee commented on KAFKA-8950:
Believe we're also running into this. High throughput topics/partitions
16 matches
Mail list logo
