syslogng_kafka provides a Python module for syslog-ng 3.7 allowing one to filter and forward syslog messages to Apache Kafka brokers.
The implementation leverages confluent-kafka which uses the awesome librdkafka library providing reliability and high performance.
Please read the doc as in most cases a `pip install` won't work as they are particular requirements that are currently not met by mainstream Linux distributions.