zouyi
zouyi
微信公众号：小道消息、VanillaOpenResty开发、TimYang、神秘的程序员们、黑夜路人技术
this lib needs a lot of work to do to move on.
kafka 1.1.1 filebeat 6.4.0 php 7.1.11 kafka-php v0.2.0.8 我定位问题出现在 filebeat传输给 kafka 的时候默认配置compression: gzip 所以数据是压缩的，但是 php 的 gzdecode 还原出来的数据仍有乱码，如果 filebeat 收集发给 kafka 时设置 compression: none 就没有问题。 kafka-php 中 nmred/kafka-php/src/Kafka/Protocol/Protocol.php 方法 decodeString($data,...
nmred/kafka-php 更新到 dev-master 似乎解决了，继续研究中。
我临时的解决方案是 filebeat 既然是 json 我就手动 gzdecode 之后用 `{` 截取后面正常的数据然后做处理 我后来改用 dev-master 版本似乎可以识别是否压缩并返回正常数据，但引入了新问题，取不到消费的偏移量，每次消费完以后又重复消费了
finally i found my anwser, I can add closure like this in where() function ``` [ ["id","!=","1"], [function($query) { $query->whereIn('id', ['1','2','3']); }] ] ```
可以可以，点个赞，就是omnipay/common v3 需要php 7.1以上版本坑了，我只能继续用v3.0-alpha.1的omnipay/common 了
cli 模式下报错注释掉 molten.notify_uri设置后重试 php-fpm 下无法请求问题请检查 curl 与 molten 扩展的加载顺序，molten 需要后加载
可以结贴了，不支持swoole。