Tails logs from Kafka and pushes to Grafana Loki in an ordered manner
100K+
tail -f > loki = floki
Floki is a simple micro-service that aggregates Kafka logs, sorts them and pushes them to Grafana Loki.

Loki has Promtail which is an agent that installs itself in every k8s cluster nodes and collects the pods logs and sends them to Loki. Since we use the ELK Stack in our infrastructure, each k8s node has the Filebeat agent running for log collection, so by using Promtail, we are effectively duplicating the functionality. To avoid this, we have created Floki, which subscribes to our Kafka logging topics, orders the logs and sends them to Loki.
To run Floki, you need to have the ELK Stack or other distributed logging system compatible with Kafka and also Loki installed in your infrastructure.
docker run nosinovacao/floki \
-lokiurl="http://<loki_base_url>/api/prom/push" \
-brokerList="<kafka_broker_list>" \
-topicPattern="^logging-*"
See the open issues for a list of proposed features (and known issues).
Contributions are what make the open source community such an amazing place to be learn, inspire, and create. Any contributions you make are greatly appreciated.
git checkout -b feature/AmazingFeature)git commit -m 'Add some AmazingFeature')git push origin feature/AmazingFeature)Distributed under the BSD-3-Clause License. See LICENSE for more information.
Content type
-
Digest
Size
-
Last updated
over 5 years ago
docker pull nosinovacao/floki