Oleg Muravskiy created KAFKA-9173:
-------------------------------------
Summary: StreamsPartitionAssignor assigns partitions to only one
worker
Key: KAFKA-9173
URL: https://issues.apache.org/jira/browse/KAFKA-9173
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.2.1, 2.3.0
Reporter: Oleg Muravskiy
Attachments: StreamsPartitionAssignor.log
I'm running a distributed KafkaStreams application on 10 worker nodes,
subscribed to 21 topics with 10 partitions in each. I'm only using a Processor
interface, and a persistent state store.
However, only one worker gets assigned partitions, all other workers get
nothing. Restarting the application, or cleaning local state stores does not
help. StreamsPartitionAssignor migrates to other nodes, and eventually picks up
other node to assign partitions to, but still only one node.
It's difficult to figure out where to look for the signs of problems, I'm
attaching the log messages from the StreamsPartitionAssignor. Let me know what
else I could provide to help resolve this.
[^StreamsPartitionAssignor.log]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
