php rdkafka如何开始使用

要开始使用php rdkafka，首先需要安装rdkafka扩展。可以通过以下命令使用pecl来安装：

pecl install rdkafka

安装完成后，在php.ini文件中添加以下内容来启用rdkafka扩展：

extension=rdkafka.so

然后可以在PHP代码中使用rdkafka扩展来编写Kafka生产者和消费者。以下是一个简单的示例：

set('metadata.broker.list', 'localhost:9092');

$producer = new RdKafka\Producer($conf);
$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);
}

echo "Messages sent successfully\n";

$consumer = new RdKafka\Consumer($conf);
$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";
    }
}

$consumer->consumeStop(0);

这是一个简单的示例，它创建了一个Kafka生产者来发送消息，并创建一个Kafka消费者来接收消息。您可以根据自己的需求进一步扩展和定制这段代码。