consumer读取message进行gzdecode之后，仍然携带乱码

jiajun-artist commented 7 years ago

用example里面的Consumer.php进行读取Kafka, (Kafka里的消息是json格式的单行字符串，flume端producer进行gzip的compression) , 拿到message之后进行gzdecode之后在结果之前仍然携带一小段的乱码。不清楚需要怎么处理

拿到的message是 URK��0 M{�B��J�G�z�鲋�YR#�e�r&A��=G/�3��S2�'��陻ݿ��ǯx��n��B��W�L��:�:��A��#(�=�&L(x�5�*�Gt � /�L��?0��q�TnÀ�xF��Hͬ��8�x ��OG �9�C��ω�&�g�[�D�yD��R7�F�d��f�~y�'z��u�H��Zp� �ʬ�^g��yU�VjvM��n�KR�McJUj/T)5�z�͐�G<�v�n�n�~Fd�wY�� P��@�]��X'�%r-r^��䢨�'��4V�U��uNa��M,��CXnTB�v�M��eP��

gzdecode之后 ��tf��{"date":"2017-07-19T18:20:00+08:00","ip":"127.0.0.1","node":"hk-243", "domain":"xxx","api":"list","icc":"ke","method":"GET","protocol":"HTTP/1.0","code":200,"range":"","bytes":1932,"adnums":"1","allow_type":"","res_type":"","exec":"0.0064","uuid":"c39218d0-0c85-4ee9-8cef-683cade1ddab","channel":"xxx","vcode":"1","gaid":"2308bba0-3715-4e2a-bac7-c27e0060ceab","app":"xxx","imei":"123123123","imsi":"123123","group":"abc","androidid":"123123123","model":"","net":"wifi","producer":"scx35_it1408","reso":"480x800","upaddr":"192.168.101.246:9001","upst":"200","rest":"0.010","trigger":"","icc":"ke","osv":"22","pkg":"","tp":""}

nmred commented 7 years ago

提供一下你consumer中 setVersion 的版本号和你 kafka Broker 版本号

superbogy commented 5 years ago

+1

weiboad / kafka-php

consumer读取message进行gzdecode之后，仍然携带乱码 #118