README

使用 arnaud-lb/php-rdkafka 客户端进行消息生产，Apache Kafka 处理器。

安装

要安装 Kafka 处理器 for Monolog，请在您的 composer.json 文件中添加依赖项

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

并运行以更新您的供应商

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

请确保在您的 php.ini 文件中安装并启用了 php-rdkadka 扩展。您还可以考虑安装一个 kwn/php-rdkafka-stubs 软件包，该软件包为您的 IDE 中的 php-rdkafka 提供一组存根。

用法

为了使用 Kafka 处理器 for Monolog，您需要创建一个 \RdKafka\ProducerTopic 实例，并将其注入到 Kafka 处理器中。通常这应该在您的依赖注入容器中完成。以下是一个简单的代码示例，展示如何创建所有必要的元素：

<?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');

kwn / monolog-kafka-handler

维护者

详细信息

README

安装

用法