README

安装 Kafka 生产者包装器

  composer require nirmalsharma/laravel-kafka-producer

示例

Laravel 6

在代码中使用 Kafka。

在 web.php 中添加以下内容

use KafkaProducer;

$topic = "kafka-topic";
$data = [
    "user_ref" => "usr.123456",
    "message" => "Hello World"
];
$key = "usr.123456"; // Optional, Default null
$headers = [
    "ContentType" => "application/json",
    "Timezone" => "GMT +05:30"
]; // Optional
Kafka::push($topic, $data, $key, $headers);

环境变量

要运行此程序，您需要将以下环境变量添加到您的 .env 文件中。配置参考：[https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md](https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md)

IS_KAFKA_ENABLED=             // Default:  1
KAFKA_BROKERS=
KAFKA_DEBUG=                  // Default: false
KAFKA_SSL_PROTOCOL=           // Default: plaintext
KAFKA_COMPRESSION_TYPE=       // Default: none
KAFKA_IDEMPOTENCE=            // Default: false

sharma_nirmal / laravel-kafka-producer

维护者

详细信息

README

示例

在代码中使用 Kafka。

环境变量

作者

许可证

特性