This PHP library provides a convenient way to produce messages to Kafka topics using the RdKafka PHP extension.
-
Requirements:
- RdKafka PHP extension (Installation Instructions)
-
Installation via Composer:
You can install the library via Composer. Run the following command in your terminal:
composer require twidpay/utils
-
Usage:
- All possible configurations for the KafkaProducer can be found here
use Utils\queue\KafkaProducer; $config = [ 'metadata.broker.list' => 'localhost:9092', 'compression.codec' => 'snappy', 'security.protocol' => 'ssl', //other kafka configuration ]; $this->kafkaProducer = new KafkaProducer($config); //key is optional $this->kafkaProducer->produce($topic, $message, $key);