消息中间件Kafka（PHP版本）

在PHP中使用Kafka，你可以使用php-kafka库。以下是一个简单的例子，展示了如何使用这个库发送消息到Kafka。

首先，确保你已经通过Composer安装了php-kafka库：

composer require nmred/kafka-php

然后，你可以使用以下代码发送消息：

<?php
 
require 'vendor/autoload.php';
 
use RdKafka\Producer;
use RdKafka\Topic;
use RdKafka\ProducerTopic;
use RdKafka\ProducerConfig;
 
// 配置Kafka生产者
$conf = new ProducerConfig();
$conf->set('metadata.broker.list', 'your_broker:9092'); // 替换为你的broker地址和端口
 
// 创建生产者实例
$producer = new Producer($conf);
 
// 创建主题实例
$topic = new Topic($producer, 'your_topic'); // 替换为你的topic名称
 
// 创建生产者主题实例
$producerTopic = new ProducerTopic($topic);
 
// 发送消息
$message = 'Hello, Kafka!';
$producerTopic->produce(RD_KAFKA_PARTITION_UA, 0, $message);
 
// 刷新消息（确保它们被发送）
$producerTopic->getProducer()->poll(0);
 
?>

确保替换 'your_broker:9092' 和 'your_topic' 为你的Kafka broker地址和topic名称。

这个例子创建了一个生产者实例，指定了要连接的Kafka代理，然后创建了一个主题实例，在这个主题上生产消息。produce 方法的第一个参数指定了分区，第二个参数是消息的优先级，第三个参数是消息内容。最后，调用 poll 方法确保消息被发送。