tail2kafka is a linux tool for sending log lines into a kafka topic.
It supports local and remote kafka servers, log rotation and batching messages to kafka.
Based off of harelba's tail2kafka and adapted to Kafka 0.8 by mmlac using kafka-python by mumrah
pip install virtualenv virtualenv venv source venv/bin/activate pip install git+https://firstname.lastname@example.org python setup.py install
Still throws an error on KeyboardInterrupt. Feel free to patch it, it should however not impact the operation of the tool.
Any feedback/suggestions/complaints regarding this tool would be much appreciated. Contributions are most welcome as well, of course.
Harel Ben-Attia, email@example.com, @harelba on Twitter for the initial tail2kafka
Markus Lachinger, firstname.lastname@example.org, @mLachinger, blog.mmlac.com for adaption to Kafka 0.8