Ottomata has uploaded a new change for review. ( 
https://gerrit.wikimedia.org/r/367403 )

Change subject: Use different consumer group for the mysql eventbus 
eventlogging consumer
......................................................................

Use different consumer group for the mysql eventbus eventlogging consumer

Change-Id: I501485cee745226fba5c632a593aa84090d761e0
---
M modules/role/manifests/eventlogging/analytics/mysql.pp
1 file changed, 2 insertions(+), 3 deletions(-)


  git pull ssh://gerrit.wikimedia.org:29418/operations/puppet 
refs/changes/03/367403/1

diff --git a/modules/role/manifests/eventlogging/analytics/mysql.pp 
b/modules/role/manifests/eventlogging/analytics/mysql.pp
index c05b08b..b072024 100644
--- a/modules/role/manifests/eventlogging/analytics/mysql.pp
+++ b/modules/role/manifests/eventlogging/analytics/mysql.pp
@@ -35,7 +35,6 @@
         'eventlogging_mysql_consumers',
         ['mysql-m4-master-00']
     )
-    $kafka_consumer_group = 'eventlogging_consumer_mysql_00'
 
     # Where possible, if this is set, it will be included in client 
configuration
     # to avoid having to do API version for Kafka < 0.10 (where there is not a 
version API).
@@ -75,7 +74,7 @@
         # auto commit offsets to kafka more often for mysql consumer
         input  => 
"${filter_scheme}${kafka_consumer_uri}&auto_commit_interval_ms=1000${kafka_api_version_param}${filter_function}",
         output => 
"mysql://${mysql_user}:${mysql_pass}@${mysql_db}?charset=utf8&statsd_host=${statsd_host}&replace=True",
-        sid    => $kafka_consumer_group,
+        sid    => 'eventlogging_consumer_mysql_00',
         # Restrict permissions on this config file since it contains a 
password.
         owner  => 'root',
         group  => 'eventlogging',
@@ -107,7 +106,7 @@
         # Load and cache local (EventBus) schemas so those events can be 
inserted into MySQL too.
         # This will require a restart of the consumer process(es) when there 
are any new schemas.
         schemas_path => "${::eventschemas::path}/jsonschema",
-        sid          => $kafka_consumer_group,
+        sid          => 'eventlogging_consumer_mysql_eventbus_00'
         # Restrict permissions on this config file since it contains a 
password.
         owner        => 'root',
         group        => 'eventlogging',

-- 
To view, visit https://gerrit.wikimedia.org/r/367403
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: I501485cee745226fba5c632a593aa84090d761e0
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

Reply via email to