PHP rdkafka能消费消息吗

是的，PHP的RdKafka扩展可以用于消费Kafka消息。RdKafka是一个基于libkafka的高性能、可扩展的PHP Kafka客户端库，它提供了对Kafka 0.8及更高版本的支持。

要使用RdKafka消费消息，你需要创建一个消费者，然后订阅一个或多个主题。以下是一个简单的示例：

<?php
// 引入autoload文件
require_once 'vendor/autoload.php';

// 创建一个新的RdKafka消费者实例
$conf = new \RdKafka\Conf();
$conf->set('group.id', 'myGroup'); // 设置消费者组ID
$conf->set('bootstrap.servers', 'localhost:9092'); // 设置Kafka服务器地址
$consumer = new \RdKafka\KafkaConsumer($conf);

// 订阅一个或多个主题
$consumer->subscribe(['myTopic']);

// 开始消费消息
while (true) {
    $message = $consumer->consume(120*1000);

    switch ($message->err) {
        case RD_KAFKA_RESP_ERR__PARTITION_EOF:
            echo "Reached end of partition event\n";
            break;
        case RD_KAFKA_RESP_ERR__TIMED_OUT:
            echo "Timed out\n";
            break;
        case RD_KAFKA_RESP_ERR__PARTITION_NOT_FOUND:
            echo "Partition not found\n";
            break;
        case RD_KAFKA_RESP_ERR__UNKNOWN:
            echo "Unknown error\n";
            break;
        default:
            echo "Message received: " . $message->payload . "\n";
            break;
    }
}

// 销毁消费者实例
$consumer->close();
?>

在这个示例中，我们首先创建了一个RdKafka消费者实例，并设置了消费者组ID和Kafka服务器地址。然后，我们订阅了一个名为’myTopic’的主题。最后，我们进入一个无限循环，不断消费消息。当接收到消息时，我们打印出消息的内容。