Hi all,
As you may have all known already, We are going to develop a new feature, Kafka source for syslog-ng product during this GSoC 2016 under the guidance of Viktor Juhasz.
A simple abstract idea of this project is,
The syslog-ng application can read messages from the sources. It
processes them with filters, rewrite rules, parsers and finally sends
messages to their destinations. The syslog-ng application already has a
Kafka destination that is implemented in Java. The Kafka source will
allow syslog-ng to read messages from Kafka, for an example this can be used for
example as a queue between several syslog-ng instances.
-Use Kafka consumer which uses the high level Kafka group consuming API.