xianle cao created TUBEMQ-555: --------------------------------- Summary: short session data can only be written to a specific partition Key: TUBEMQ-555 URL: https://issues.apache.org/jira/browse/TUBEMQ-555 Project: Apache TubeMQ Issue Type: Bug Components: Client Reporter: xianle cao
When a user uses a short session to write data, it starts from 0 each time, so the data can only be written to a fixed partition, which causes an imbalance problem. className: RoundRobinPartitionRouter.class code: ``` AtomicInteger newCounter = new AtomicInteger(0); ``` solution: ``` AtomicInteger newCounter = new AtomicInteger(new Random().nextInt()); ``` -- This message was sent by Atlassian Jira (v8.3.4#803005)