php如何设置kafka手动提交消费ack？
网友回复
设置('enable.auto.commit', 'false');
消费完数据后进行 $consumer->commit($message);
示例代码如下：
<?php
$conf = new RdKafka\Conf();
// Set a rebalance callback to log partition assignments (optional)
// 当有新的消费进程加入或者退出消费组时，kafka 会自动重新分配分区给消费者进程，这里注册了一个回调函数，当分区被重新分配时触发
$conf->setRebalanceCb(function (RdKafka\KafkaConsumer $kafka, $err, array $partitions = null) {
switch ($err) {
case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS:
echo "Assign: ";
var_dump($partitions);
$kafka->assign($partitions);
break;
case RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS:
echo "Revoke: ";
var_dump($partitions);
$kafka->assign(NULL);
break;
default:
...点击查看剩余70%
by thinkfuture
我知道答案，我要回答
私活外包
最新提问
浏览器中实时摄像头离线视觉ai模型有吗？
如何让ai基于Chromium内核开发自己的windows浏览器？
如何将自己从小生活的农村村庄做成3d可漫游的高斯泼溅？
同一个iframe多次write包含three的html为啥报错不显示Failed to execute 'write' on 'Document': Identifier 'scene' has a
软件工程师的工作内容将由敲代码转变成使用ai来解决现实世界的问题？
claude skills如何本地自动剪辑生成视频？
物理ai是2026年的趋势吗？
ai能对老相机拍摄的底片进行修复成彩色照片吗?
PlayCanvas能在浏览器中交互展示4dgs高斯泼溅文件吗？
jpeg xl格式图片有啥优势？
