Webman中必须用rdkafka扩展而非纯PHP SDK，因其支持高吞吐、自动重试、背压控制等关键特性；rdkafka需pecl安装并配置php.ini，不能仅靠composer；生产者应单例复用并设delivery report回调，消费者须独立进程运行以防阻塞HTTP worker。
Webman 本身不内置 Kafka 支持，它只是一个高性能的 PHP HTTP 服务框架（基于 Workerman），要实现 Kafka 消息流处理，必须引入外部 Kafka 客户端扩展。直接在 Webman 中用 file_get_contents 或 cURL 调用 Kafka REST Proxy 是低效且不可靠的；真正能扛住高吞吐的，只有原生 C 绑定的 rdkafka 扩展。
为什么不能用 composer require ka/kafka-php 或 php-kafka 类纯 PHP SDK？
这类纯 PHP 实现的 SDK 依赖 socket + stream + 自定义协议解析，在 Webman 的常驻内存、多进程模型下会暴露严重缺陷：
- 无法复用连接：每次
new Producer()都新建 TCP 连接，Kafka broker 端连接数暴涨，容易触发Too many open files - 无真正的异步 I/O：即使 Webman 是异步框架，纯 PHP SDK 仍是阻塞式 socket read/write，
poll()会卡住整个 worker 进程 - 不支持 librdkafka 的高级特性：如自动重试、背压控制、linger.ms、batch.size、offset 提交策略等，这些对「超高吞吐」是刚需
- 消息序列化/反序列化全在 PHP 层做，CPU 开销大，而
rdkafka可通过message.timestamp.type、enable.idempotence等参数交由 C 层优化
rdkafka 扩展必须用 pecl 安装，不能只靠 composer
composer require ext-rdkafka 只是声明依赖，**不会安装扩展本身**。缺少系统级扩展，运行时会报：Class 'RdKafka\Producer' not found 或 PHP Startup: Unable to load dynamic library 'rdkafka'。
正确安装路径（Linux）：
立即学习“PHP免费学习笔记（深入）”；
- 先装系统依赖：
sudo apt-get install librdkafka1-dev pkg-config（Ubuntu/Debian）或yum install librdkafka-devel（CentOS） - 再用 pecl 安装扩展：
pecl install rdkafka - 确认启用：在
php.ini中加入extension=rdkafka，并重启 Webman（php start.php restart） - 验证：
php -m | grep rdkafka应输出rdkafka
Webman 中正确启动 Kafka 生产者：别在 onWorkerStart 里 new Producer
很多用户把 RdKafka\Producer 实例创建放在 onWorkerStart 回调里，看似“每个 worker 一个实例”，实则埋下大坑：
-
RdKafka\Producer是线程不安全的，但 Webman 的 worker 进程是单线程、协程安全（非多线程），所以单实例可复用 —— 但必须确保它不被多个协程并发调用produce()而未加锁 - 更稳妥做法：使用
static $producer单例 +yield等待poll()，或封装为Channel队列中转（避免阻塞） - 关键配置必须设：
$conf->set('queue.buffering.max.messages', '100000')和$conf->set('batch.num.messages', '1000')，否则默认缓冲太小，高并发下频繁 flush，吞吐上不去 - 务必设置 delivery report 回调：
$conf->setDrMsgCb(...)，否则无法感知发送失败（如网络抖动、broker 不可用），消息会静默丢失
Kafka 消费者不能长期挂起在 Webman 的 HTTP worker 里
Webman 的 HTTP worker 是为响应请求设计的，不是为长周期消费任务准备的。把 RdKafka\KafkaConsumer 启动在 onWorkerStart 并调用 consume() 循环，会导致：
- HTTP 请求无法进入：worker 被消费循环占满，不再接受新连接
- 无法优雅退出：Webman reload 时，consumer 不会自动 commit offset，可能重复消费
- 心跳超时：默认
session.timeout.ms=45000，若业务处理慢（如调用第三方 API），broker 会踢出 consumer，触发 rebalance
正确做法：用独立的守护进程跑消费者（如 php consumer.php start -d），与 Webman 解耦；或使用 Webman 的 process 机制，在单独子进程中启动 consumer，并通过 ProcessManager 管理生命周期和信号处理（如收到 SIGTERM 时 commit offset 再退出）。
Webman 做 Kafka 流处理的复杂点不在代码量，而在资源归属权的厘清：HTTP worker 只负责快速收发、入队；真正耗时、长连接、状态敏感的操作（如消费、批量投递、exactly-once 控制），必须剥离到专用进程。忽略这点，吞吐再高也撑不过压测五分钟。
