guozhangwang commented on PR #13920: URL: https://github.com/apache/kafka/pull/13920#issuecomment-1656811793
@flashmouse Thanks! I echo other's thoughts that in a unit test, we could refrain ourselves from trying very large scale when trying to validate a specific logic or expose a bug. Just giving a data point here, in StreamsAssignmentScaleTest which is an integration test, given the goal is actually to validate that the assignor is efficient enough such that it can complete the assignment task within a certain time, our scale is around 1000 - 6000 partitions with 2 clients only. I'm actually wondering if this bug could be exposed with a even small scale, like `3 consumers and 4 partitions` at all? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org