Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
RdKafkaConnectionFactory
✓ use Enqueue\RdKafka\RdKafkaConnectionFactory;
Send a message to a Kafka topic.
<?php
require 'vendor/autoload.php';
use Enqueue\RdKafka\RdKafkaConnectionFactory;
$factory = new RdKafkaConnectionFactory(['global' => ['group.id' => 'test', 'metadata.broker.list' => 'localhost:9092']]);
$context = $factory->createContext();
$message = $context->createMessage('Hello Kafka');
$context->createProducer()->send($context->createTopic('test'), $message);
Upgrade
Version history
0.10.27latest on Packagist
Audit
Dependencies
No dependency data recorded yet.