create topic disk allocate strategy per broker#5970
create topic disk allocate strategy per broker#5970seayoun wants to merge 2 commits intoapache:trunkfrom
Conversation
…ll into non-stop loop and send more message to broker, and Stat in PerfCallback method record will throw ArrayIndexOutOfBoundsException
… partition count in each directory and then count by total partitions in each directory; first consider is topic level balance, because topic flow is not equal , such huge flow and small flow
|
retest this please. |
| int currentTransactionSize = 0; | ||
| long transactionStartTime = 0; | ||
| for (int i = 0; i < numRecords; i++) { | ||
| for (long i = 0; i < numRecords; i++) { |
There was a problem hiding this comment.
I have already merged this change as part of #5956
|
@seayoun Request you to create a JIRA and describe the requirement/change. This will be useful to understand/track the changes. |
|
ok, thank you |
I submit an issue on jira https://issues.apache.org/jira/browse/KAFKA-7690 , I am Looking forward to your suggestions. |
discuss here https://issues.apache.org/jira/browse/KAFKA-7690 |
|
This PR is being marked as stale since it has not had any activity in 90 days. If you If you are having difficulty finding a reviewer, please reach out on the [mailing list](https://kafka.apache.org/contact). If this PR is no longer valid or desired, please feel free to close it. If no activity occurs in the next 30 days, it will be automatically closed. |
|
This PR has been closed since it has not had any activity in 120 days. If you feel like this |
3 participants
More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.
Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.
Committer Checklist (excluded from commit message)