Wallogit.com
2017 © Pedro Peláez
Apache Kafka handler for Monolog
, (*1)
Apache Kafka handler using arnaud-lb/php-rdkafka client for message producing., (*2)
In order to install Kafka handler for Monolog add a dependency in your composer.json file:, (*3)
{
"require": {
"kwn/monolog-kafka-handler": "^1.0.0",
}
}
And update your vendors by running:, (*4)
$ 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., (*5)
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:, (*6)
<?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');
Apache Kafka handler for Monolog
MIT
monolog apache handler kafka rdkafka