This daemon polls logs from kafka topics and writes it to a unix-domain-socket(for logdata-anomaly-miner)

sudo make install

After that set owner of /var/lib/akafka to aminer-user:

sudo chown aminer:aminer /var/lib/akafka

It is possible to configure akafka via configuration file which must be located at '/etc/aminer/kafka.conf' or via environment variables. A sample of the configuration file can be found at etc/kafka.conf The following environment variables are available:

sudo /usr/local/bin/akafkad.py

sudo systemctl enable akafkad
sudo systemctl start akafkad

Normally the daemon starts polling the elasticsearch as soon as some other programm reads from the unix-domain-socket. It is possible to read from the socket manually using ncat(from nmap) as follows:

sudo ncat -U /var/lib/akafka/aminer.sock

The following command will uninstall akafka but keeps the configuration file:

sudo make uninstall