Ottomata has uploaded a new change for review.
https://gerrit.wikimedia.org/r/231781
Change subject: Disable kafka auto leader rebalance
......................................................................
Disable kafka auto leader rebalance
Attempting to get Camus to sync without doing drastic things to the cluster
Change-Id: I7ceeacab2d7424fd04a1d348eb63c12efe1530bb
---
M manifests/role/analytics/kafka.pp
M modules/kafka
2 files changed, 7 insertions(+), 0 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/operations/puppet
refs/changes/81/231781/1
diff --git a/manifests/role/analytics/kafka.pp
b/manifests/role/analytics/kafka.pp
index 5aec729..c0c19a5 100644
--- a/manifests/role/analytics/kafka.pp
+++ b/manifests/role/analytics/kafka.pp
@@ -151,6 +151,13 @@
# This will be used for eventlogging-kafka
# (Disable this until we are ready for eventlogging-kafka).
auto_create_topics_enable => false,
+
+ # (Temporarily?) disable auto leader rebalance.
+ # I am having issues with analytics1012, and I can't
+ # get Camus to consume properly for its preferred partitions
+ # if it is online and the leader. - otto
+ auto_leader_rebalance_enable => false,
+
default_replication_factor => min(3, size($brokers_array)),
# Start with a low number of (auto created) partitions per
# topic. This can be increased manually for high volume
diff --git a/modules/kafka b/modules/kafka
index 306aa06..6167fe8 160000
--- a/modules/kafka
+++ b/modules/kafka
-Subproject commit 306aa069d200d33b176e0900d4596efdb9ade405
+Subproject commit 6167fe8221c0fd3d14f9639ffc0af48a7b52f403
--
To view, visit https://gerrit.wikimedia.org/r/231781
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I7ceeacab2d7424fd04a1d348eb63c12efe1530bb
Gerrit-PatchSet: 1
Gerrit-Project: operations/puppet
Gerrit-Branch: production
Gerrit-Owner: Ottomata <[email protected]>
_______________________________________________
MediaWiki-commits mailing list
[email protected]
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
