Apache Kafka handler for Monolog

Apache Kafka handler using arnaud-lb/php-rdkafka client for message producing.

Installation

In order to install Kafka handler for Monolog add a dependency in your composer.json file:

{
    "require": {
        "kwn/monolog-kafka-handler": "^1.0.0",
    }
}

And update your vendors by running:

$ php composer.phar update kwn/monolog-kafka-handler

Make sure the php-rdkadka extension is installed and enabled in your php.ini file. You can also consider installing a kwn/php-rdkafka-stubs package, which provides a set of stubs for php-rdkafka in your IDE.

Usage

In order to use Kafka handler for Monolog, you need to create an instance of \RdKafka\ProducerTopic, and inject it using constructor in Kafka handler. Normally it should happen in your dependency injection container. Simple code showing how to create all necessary elements could be found below:

<?php

use Monolog\Logger;
use RdKafka\Producer;
use Kwn\Monolog\Handler\KafkaHandler;

$producer = new Producer();
$producer->addBrokers('localhost:9092');

$producerTopic = $producer->newTopic('test');

$handler = new KafkaHandler($producerTopic);
$handler->setFormatter(new LineFormatter('%message%'));

$monolog = new Logger('kafka-logger');
$monolog->pushHandler($handler);

$monolog->error('something went wrong');