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
我知道答案，我要回答
私活外包
最新提问
webrtc进行p2p连接发送的文本音视频文件是否是加密的？
如何让一个可爱的三维动物通过three在浏览器中有表情动作的自然说话？
go与wails如何开发一个高性能的原生桌面应用？
python如何调用openai的api实现知识讲解类动画讲解视频的合成？
html如何直接调用openai的api实现海报可视化设计及文本描述生成可编辑海报？
f12前端调试如何找出按钮点击事件触发的那段代码进行调试？
abcjs如何将曲谱播放后导出mid和wav格式音频下载？
python如何将曲子文本生成音乐mp3或wav、mid文件
python中mp3、wav音乐如何转成mid格式？
js在HTML中如何将曲谱生成音乐在线播放并下载本地？
