Extract raw data sent to kafka (such as data from collectd) and republish them into timeseries-like topics that can be consumed by other applications (such as NI-Mon or NI-AI-module).
Python 2.7
Currently, only collectd_extractor is used:
python kafka_extractor/collectd_extractor.py
The config file also shows which topic available for consume:
vi config/config.yaml
We use kafdrop 3 to monitor available topics and data. This should be automatically installed with Kafka Extractor if using ni-testbed ansible script.
http://localhost:9000