PHP client library for Apache Kafka
kafka-php allows you to produce messages to the Apache Kafka distributed publish/subscribe messaging service.
Add the lib directory to the PHP include_path and use an autoloader like the one in the examples directory (the code follows the PEAR/Zend one-class-per-file convention).
The examples directory contains an example of a Producer and a simple Consumer, and an example of the Zookeeper-based Consumer.
Example Producer:
$producer = new Kafka_Producer('localhost', 9092, Kafka_Encoder::COMPRESSION_NONE); $messages = array('some', 'messages', 'here'); $topic = 'test'; $bytes = $producer->send($messages, $topic);
Example Consumer:
$topic = 'test'; $partition = 0; $offset = 0; $maxSize = 1000000; $socketTimeout = 5;while (true) { $consumer = new Kafka_SimpleConsumer('localhost', 9092, $socketTimeout, $maxSize); $fetchRequest = new Kafka_FetchRequest($topic, $partition, $offset, $maxSize); $messages = $consumer->fetch($fetchRequest); foreach ($messages as $msg) { echo "\nMessage: " . $msg->payload(); } //advance the offset after consuming each MessageSet $offset += $messages->validBytes(); unset($fetchRequest); }
Lorenzo Alberton
l.alberton at(@) quipo.it
http://twitter.com/lorenzoalberton
http://alberton.info/