如何将php api日志以二进制格式导入kafka

<?php
$conf = new RdKafka\Conf();
$conf->set('metadata.broker.list', 'kafka_broker1:9092,kafka_broker2:9092'); // 设置Kafka的地址和端口
$producer = new RdKafka\Producer($conf);

$topic = $producer->newTopic('api_logs'); // 设置Kafka的主题名称

$logData = 'API日志数据'; // 从日志文件中读取API日志数据

$producer->produce(RD_KAFKA_PARTITION_UA, 0, $logData); // 将API日志数据发送到Kafka

$producer->flush(1000); // 刷新并等待消息发送完成

echo 'API日志已成功导入Kafka。';
?>