- 7月 25, 2020
-
-
由 Arvind Thirunarayanan 创作于
* reset mk-include * Squashed 'mk-include/' content from commit 515ee6e6f1 git-subtree-dir: mk-include git-subtree-split: 515ee6e6f161b31758aae206b47158bdbedcb80e
-
由 Harini Rajendran 创作于
-
由 Brian Byrne 创作于
- 7月 24, 2020
-
-
由 Stanislav Kozlovski 创作于
CNKAF-1015: Fix issue in SBK startup by moving CruiseControl instantiation after the startup components (#2233) The SBK system tests caught a regression in master (from CNKAF-762) where Cruise Control cannot start due to not being able to find the telemetry reporter's topic
-
由 Brian Byrne 创作于
-
由 Matthew Wong 创作于
-
由 Rajini Sivaram 创作于
Reviewers: Sanjana Kaundinya
- 7月 23, 2020
-
-
由 Brian Byrne 创作于
-
由 Brian Byrne 创作于
-
由 Soumyarka Mondal 创作于
reviewer: @rohitshekhar29
-
由 David Mao 创作于
We were previously passing in an empty string to the reassign-partitions CLI if there were no observers specified and this was causing the CLI to error. This wasn't forward-compatible with the addition of observer reassignments to the CLI. Fixed by returning an empty list instead of empty string.
-
由 Harini Rajendran 创作于
-
由 Harini Rajendran 创作于
-
由 Stanislav Kozlovski 创作于
This patch introduces a system test for altering the replica placement constraints for a topic and then verifying that SBK's self-healing rebalances the topic such that the constraints are respected
- 7月 22, 2020
-
-
由 Srini Dandu 创作于
Signed-off-by: sdanduConf <sdandu@confluent.io>
-
由 Stanislav Kozlovski 创作于
This patch renames all "SBK" occurrences in logs to "DataBalancer". This makes it consistent with the rest of the DataBalancer logs and ensures the operator isn't confused by the two terms we use interchangeably
-
由 Brian Bushree 创作于
-
由 xiaodongdu 创作于
-
由 Brian Byrne 创作于
Conflicts: Jenkinsfile core/src/main/scala/kafka/cluster/Partition.scala core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala core/src/main/scala/kafka/log/LogManager.scala core/src/main/scala/kafka/server/ReplicaManager.scala core/src/test/scala/unit/kafka/log/LogManagerTest.scala core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala tests/kafkatest/services/kafka/kafka.py Changes to address test failure: core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala
-
由 Steve Rodrigues 创作于
It was previously waiting METADATA_MAX_AGE which is a different lifetime config. Because METADATA_TTL is a Long not an Int, adjust the backoff() utility as well. Also, reduce frequency of logging when broker search (for addBroker) succeeds.
- 7月 21, 2020