[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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 

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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.

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ 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