不支持一次消费多条消息么

[xiaobingge]

只能一条条消息去消费么？

[Yurunsoft]

现在协议上是批量取消息，然后是内部循环每条消息，触发回调或者 $consumer->consume() 方法返回

[xiaobingge]

为啥找不到 max.poll.records 的配置 每次是取出分区所有数据在循环么

[Yurunsoft]

没有实现max.poll.records这个配置，kafka 的 Fetch 是根据等待时间、最小字节数、最大字节数来返回数据的，每次消息条数不固定。java 版的max.poll.records是在客户端层面实现，后面会考虑是否引入这个特性。