Change Details

hafnium hosts eventlogging consumers that consume from eventlogging's :8600 zmq stream of valid eventlogging events. Analytics in the process of replacing eventlogging's backend with Kafka instead of zmq. the zmq stream will soon be turned off. Instead, you can do one of the following 1. change the input URI to `kafka:///kafka1012.eqiad.wmnet:9092,kafka1013.eqiad.wmnet:9092,kafka1014.eqiad.wmnet:9092,kafka1018.eqiad.wmnet:9092,kafka1020.eqiad.wmnet:9092,kafka1022.eqiad.wmnet:9092?topic=eventlogging-valid-mixed&zookeeper_connect=conf1001.eqiad.wmnet,conf1002.eqiad.wmnet,conf1003.eqiad.wmnet/kafka/eqiad` 2. Modify your consumers to use schema based topics. The latter would be better, as you wouldn't need to filter out events that are not relevant for your consumers. Please coordinate this with @ottomata and @madhuvishy. :) Consumers: [ ] [webperf/navtiming.py](https://github.com/wikimedia/operations-puppet/blob/e1644ccc17da3ba91a984f5fdf730ef0b433a607/modules/webperf/files/navtiming.py) [ ] [webperf/ve.py](https://github.com/wikimedia/operations-puppet/blob/e1644ccc17da3ba91a984f5fdf730ef0b433a607/modules/webperf/files/ve.py) [ ] [coal](https://github.com/wikimedia/operations-puppet/blob/aa2b2054a4aaf4b6b0717a0b42d3db0eb1ed7301/modules/coal/files/coal#L131) * Search for ["import zmq" in puppet](https://github.com/wikimedia/operations-puppet/search?utf8=%E2%9C%93&q=%22import+zmq%22) * Search for ["import eventloging" in puppet](https://github.com/wikimedia/operations-puppet/search?utf8=%E2%9C%93&q=%22import+eventlogging%22&type=Code)

hafnium hosts eventlogging consumers that consume from eventlogging's :8600 zmq stream of valid eventlogging events. Analytics in the process of replacing eventlogging's backend with Kafka instead of zmq. the zmq stream will soon be turned off. Instead, you can do one of the following 1. change the input URI to `kafka:///kafka1012.eqiad.wmnet:9092,kafka1013.eqiad.wmnet:9092,kafka1014.eqiad.wmnet:9092,kafka1018.eqiad.wmnet:9092,kafka1020.eqiad.wmnet:9092,kafka1022.eqiad.wmnet:9092?topic=eventlogging-valid-mixed&zookeeper_connect=conf1001.eqiad.wmnet,conf1002.eqiad.wmnet,conf1003.eqiad.wmnet/kafka/eqiad` 2. Modify your consumers to use schema based topics. Consumers: [ ] [webperf/navtiming.py](https://github.com/wikimedia/operations-puppet/blob/e1644ccc17da3ba91a984f5fdf730ef0b433a607/modules/webperf/files/navtiming.py) [ ] [webperf/ve.py](https://github.com/wikimedia/operations-puppet/blob/e1644ccc17da3ba91a984f5fdf730ef0b433a607/modules/webperf/files/ve.py) [ ] [coal](https://github.com/wikimedia/operations-puppet/blob/aa2b2054a4aaf4b6b0717a0b42d3db0eb1ed7301/modules/coal/files/coal#L131) * Search for ["import zmq" in puppet](https://github.com/wikimedia/operations-puppet/search?utf8=%E2%9C%93&q=%22import+zmq%22) * Search for ["import eventloging" in puppet](https://github.com/wikimedia/operations-puppet/search?utf8=%E2%9C%93&q=%22import+eventlogging%22&type=Code)

hafnium hosts eventlogging consumers that consume from eventlogging's :8600 zmq stream of valid eventlogging events. Analytics in the process of replacing eventlogging's backend with Kafka instead of zmq. the zmq stream will soon be turned off. Instead, you can do one of the following 1. change the input URI to `kafka:///kafka1012.eqiad.wmnet:9092,kafka1013.eqiad.wmnet:9092,kafka1014.eqiad.wmnet:9092,kafka1018.eqiad.wmnet:9092,kafka1020.eqiad.wmnet:9092,kafka1022.eqiad.wmnet:9092?topic=eventlogging-valid-mixed&zookeeper_connect=conf1001.eqiad.wmnet,conf1002.eqiad.wmnet,conf1003.eqiad.wmnet/kafka/eqiad` 2. Modify your consumers to use schema based topics. The latter would be better, as you wouldn't need to filter out events that are not relevant for your consumers. Please coordinate this with @ottomata and @madhuvishy. :) Consumers: [ ] [webperf/navtiming.py](https://github.com/wikimedia/operations-puppet/blob/e1644ccc17da3ba91a984f5fdf730ef0b433a607/modules/webperf/files/navtiming.py) [ ] [webperf/ve.py](https://github.com/wikimedia/operations-puppet/blob/e1644ccc17da3ba91a984f5fdf730ef0b433a607/modules/webperf/files/ve.py) [ ] [coal](https://github.com/wikimedia/operations-puppet/blob/aa2b2054a4aaf4b6b0717a0b42d3db0eb1ed7301/modules/coal/files/coal#L131) * Search for ["import zmq" in puppet](https://github.com/wikimedia/operations-puppet/search?utf8=%E2%9C%93&q=%22import+zmq%22) * Search for ["import eventloging" in puppet](https://github.com/wikimedia/operations-puppet/search?utf8=%E2%9C%93&q=%22import+eventlogging%22&type=Code)