我正在使用来自php-rdkafka的库来存储kafka
我的示例代码是

$producer = new \RdKafka\Producer();
$producer->addBrokers('localhost:9092');
$topic = $producer->newTopic("my-topic");
$topic->produce(RD_KAFKA_PARTITION_UA, 0, $data_to_send);

当请求大量时，此代码将创建到生产者的连接。我认为解决方案是在每次生成消息完成时断开连接。因此，我将使用一个连接一次产生和断开 Kafka 之后。
然而，我的问题是如何实现这一点？我没有在 php-rdkafka 如何断开连接的文档 Kafka .