在PHP中使用Kafka可以通过使用Kafka PHP客户端库来实现。以下是一些用法示例：

生产者（Producer）：在PHP中使用Kafka生产者可以向Kafka集群发送消息。可以使用Kafka PHP客户端库中的Producer类来实现。示例代码如下：

<?phprequire('vendor/autoload.php');$producer = new RdKafka\Producer();$producer->setLogLevel(LOG_DEBUG);$producer->addBrokers('localhost:9092');$topic = $producer->newTopic('test');for ($i = 0; $i < 10; $i++) {$topic->produce(RD_KAFKA_PARTITION_UA, 0, 'Message ' . $i);}$producer->poll(0);while ($producer->getOutQLen() > 0) {$producer->poll(50);}

消费者（Consumer）：在PHP中使用Kafka消费者可以从Kafka集群订阅消息并处理。可以使用Kafka PHP客户端库中的Consumer类来实现。示例代码如下：

<?phprequire('vendor/autoload.php');$consumer = new RdKafka\Consumer();$consumer->setLogLevel(LOG_DEBUG);$consumer->addBrokers('localhost:9092');$topic = $consumer->newTopic('test');$topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);while (true) {$message = $topic->consume(0, 1000);if ($message->err) {echo "Error: {$message->errstr()}\n";break;} else {echo "Message: {$message->payload}\n";}}

这些是使用Kafka在PHP中实现生产者和消费者的一些示例。在实际应用中，可以根据具体需求进一步定制和扩展。