php 使用kafka

要在 PHP 中使用 Kafka，你需要先安装和配置 Kafka 生产者和消费者。这可以通过使用 Kafka 的官方 PHP 客户端库来完成。以下是如何在 PHP 中使用 Kafka 的步骤：

1. 安装 Kafka PHP 扩展

你可以通过 PECL 安装官方的 Kafka PHP 扩展。运行以下命令即可：

pecl install rdkafka

2. 创建 Kafka 生产者

使用以下代码创建一个 Kafka 生产者：

<?php

$conf = new RdKafka\Conf();
$conf->set('metadata.broker.list', 'localhost:9092');

$producer = new RdKafka\Producer($conf);

$topic = $producer->newTopic('my_topic');

for ($i = 0; $i < 10; $i++) {
    $message = 'Message ' . $i;
    $topic->produce(RD_KAFKA_PARTITION_UA, 0, $message);
}

$producer->flush(1000);

3. 创建 Kafka 消费者

使用以下代码创建一个 Kafka 消费者：

<?php

$conf = new RdKafka\Conf();
$conf->set('metadata.broker.list', 'localhost:9092');

$consumer = new RdKafka\Consumer($conf);

$topic = $consumer->newTopic('my_topic');

$topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);

while (true) {
    $message = $topic->consume(0, 1000);

    if (null === $message) {
        continue;
    }

    if ($message->err) {
        echo $message->errstr(), "\n";
        break;
    }

    echo $message->payload(), "\n";
}

这些代码将创建一个 Kafka 生产者和消费者，并将消息发布到名为 `my_topic` 的 Kafka 主题中。你可以根据需要调整这些代码以满足你的需求。