[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113958#comment-17113958
]
Bruno Cadonna commented on KAFKA-9173:
--
The issue that all 10 tasks are assigned to the same node is
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002531#comment-17002531
]
Matthias J. Sax commented on KAFKA-9173:
{quote}The second issue is that when 210 partitions are
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002530#comment-17002530
]
Guozhang Wang commented on KAFKA-9173:
--
Yes you're right, we still need to figure out why the
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001995#comment-17001995
]
Oleg Muravskiy commented on KAFKA-9173:
---
Well, we touched upon three issues here.
The very first
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001277#comment-17001277
]
Guozhang Wang commented on KAFKA-9173:
--
Sounds good to me.
> StreamsPartitionAssignor assigns
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001246#comment-17001246
]
Matthias J. Sax commented on KAFKA-9173:
So should we close this as "not a problem" as the system
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991991#comment-16991991
]
Matthias J. Sax commented on KAFKA-9173:
Ack
> StreamsPartitionAssignor assigns partitions to
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991960#comment-16991960
]
Sophie Blee-Goldman commented on KAFKA-9173:
[~mjsax] See
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990708#comment-16990708
]
Matthias J. Sax commented on KAFKA-9173:
[~ableegoldman] Can you help to port the CP docs to AK
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990707#comment-16990707
]
Matthias J. Sax commented on KAFKA-9173:
Seems it's only documented it Confluent docs and we
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990136#comment-16990136
]
Sophie Blee-Goldman commented on KAFKA-9173:
[~o.muravskiy] Opened [this
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989070#comment-16989070
]
Sophie Blee-Goldman commented on KAFKA-9173:
That's a good point, it does need to be
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988777#comment-16988777
]
Oleg Muravskiy commented on KAFKA-9173:
---
I understand that this is how it is *implemented*, but it
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988196#comment-16988196
]
Guozhang Wang commented on KAFKA-9173:
--
[~o.muravskiy] Sorry that I did not make myself clearer
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987696#comment-16987696
]
Oleg Muravskiy commented on KAFKA-9173:
---
[~ableegoldman] yes, I subscribe with a pattern that
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987420#comment-16987420
]
Guozhang Wang commented on KAFKA-9173:
--
[~o.muravskiy] Note that the num.tasks are not equal to
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987410#comment-16987410
]
Sophie Blee-Goldman commented on KAFKA-9173:
What exactly do you mean by "subscribed to 21
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987017#comment-16987017
]
Oleg Muravskiy commented on KAFKA-9173:
---
Hi [~ableegoldman],
I think I'm missing something there.
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986460#comment-16986460
]
Sophie Blee-Goldman commented on KAFKA-9173:
I agree we should aim to fix this, but the
[
https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972959#comment-16972959
]
Guozhang Wang commented on KAFKA-9173:
--
Hi [~o.muravskiy] it seems each one of your worker is
20 matches
Mail list logo