php向kafka写数据

要使用PHP向Kafka写入数据，你需要使用Kafka的PHP客户端库。以下是一个简单的示例代码，演示如何使用PHP向Kafka主题写入数据：

<?php
$brokers = 'localhost:9092'; // Kafka brokers
$topic = 'test'; // Kafka topic

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

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

$producer->addBrokers($brokers);

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

$message = 'Hello, Kafka!';

$topic->produce(RD_KAFKA_PARTITION_UA, 0, $message);

$producer->flush(1000); // Flush the producer buffers

echo 'Message sent to Kafka';

?>

在这个示例中，我们首先创建一个RdKafka\Conf对象，并设置Kafka的broker地址。然后，我们创建一个RdKafka\Producer对象，并将broker地址添加到它。接下来，我们创建一个RdKafka\Topic对象，用于指定要写入的主题。然后，我们使用produce()方法将消息发送到主题中。最后，我们使用flush()方法刷新生产者的缓冲区，确保消息被发送到Kafka。