Ottomata has uploaded a new change for review. https://gerrit.wikimedia.org/r/239100
Change subject: Remove non-existant broker names from list of brokers that camus uses ...................................................................... Remove non-existant broker names from list of brokers that camus uses Change-Id: I8638351258143059a0e4199b246606496d0e7d38 --- M camus/camus.eventlogging.properties M camus/camus.webrequest.properties 2 files changed, 2 insertions(+), 2 deletions(-) git pull ssh://gerrit.wikimedia.org:29418/analytics/refinery refs/changes/00/239100/1 diff --git a/camus/camus.eventlogging.properties b/camus/camus.eventlogging.properties index 0e4aee4..aa6e75e 100644 --- a/camus/camus.eventlogging.properties +++ b/camus/camus.eventlogging.properties @@ -38,7 +38,7 @@ mapred.map.tasks=25 # Connection parameters. -kafka.brokers=analytics1018.eqiad.wmnet:9092,analytics1021.eqiad.wmnet:9092,analytics1022.eqiad.wmnet:9092,kafka1012.eqiad.wmnet:9092,kafka1013.eqiad.wmnet:9092,kafka1014.eqiad.wmnet:9092,kafka1018.eqiad.wmnet:9092,kafka1020.eqiad.wmnet:9092,kafka1022.eqiad.wmnet:9092 +kafka.brokers=kafka1012.eqiad.wmnet:9092,kafka1013.eqiad.wmnet:9092,kafka1014.eqiad.wmnet:9092,kafka1018.eqiad.wmnet:9092,kafka1020.eqiad.wmnet:9092,kafka1022.eqiad.wmnet:9092 # max historical time that will be pulled from each partition based on event timestamp # Note: max.pull.hrs doesn't quite seem to be respected here. diff --git a/camus/camus.webrequest.properties b/camus/camus.webrequest.properties index b73326c..ca0e07c 100644 --- a/camus/camus.webrequest.properties +++ b/camus/camus.webrequest.properties @@ -46,7 +46,7 @@ mapred.map.tasks=60 # Connection parameters. -kafka.brokers=analytics1018.eqiad.wmnet:9092,analytics1021.eqiad.wmnet:9092,analytics1022.eqiad.wmnet:9092,kafka1012.eqiad.wmnet:9092,kafka1013.eqiad.wmnet:9092,kafka1014.eqiad.wmnet:9092,kafka1018.eqiad.wmnet:9092,kafka1020.eqiad.wmnet:9092,kafka1022.eqiad.wmnet:9092 +kafka.brokers=kafka1012.eqiad.wmnet:9092,kafka1013.eqiad.wmnet:9092,kafka1014.eqiad.wmnet:9092,kafka1018.eqiad.wmnet:9092,kafka1020.eqiad.wmnet:9092,kafka1022.eqiad.wmnet:9092 # max historical time that will be pulled from each partition based on event timestamp # Note: max.pull.hrs doesn't quite seem to be respected here. -- To view, visit https://gerrit.wikimedia.org/r/239100 To unsubscribe, visit https://gerrit.wikimedia.org/r/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I8638351258143059a0e4199b246606496d0e7d38 Gerrit-PatchSet: 1 Gerrit-Project: analytics/refinery Gerrit-Branch: master Gerrit-Owner: Ottomata <[email protected]> _______________________________________________ MediaWiki-commits mailing list [email protected] https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
