>kafka->consumer(kafka python)失败，并显示extradata:unpack(b)接收到额外数据

6ss1mwsb 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(607)

我试图解码从kafka流接收的msgpack编码的二进制消息，并在python repl中获得以下异常。
额外数据：解包（b）收到额外数据。

In [32]: message.value
Out[32]: b'\xdc\x00\x15\xd9$00000000-0000-0000-0000-000000000000\xc0\xd9$00000000-0000-0000-0000-000000000000\xc0\xc0\xd9$00000000-0000-0000-0000-000000000000\xa0\xd2X\xc8d:\xc3\xd9$3c4d1a52-536c-421a-b258-346b06097fda\xd9$1ceb5f07-b62a-4d3b-811a-d2adfce45496\xae192.168.14.177\xc2\xa9OSXEditor\xb0Mac OS X 10.12.3\xd9$c5966702-2936-4028-b911-c417cea9744f\x00\xd9$19fba27e-abf9-4be1-b8c9-eb583f3b3f61\xcd\x13\xd0\xd9$87bafec1-5368-4b5c-8368-7309a3e39a80\xca\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00'

In [33]: msgpack.unpackb(message.value)
---------------------------------------------------------------------------
ExtraData                                 Traceback (most recent call last)
<ipython-input-33-31c954e1d841> in <module>()
----> 1 msgpack.unpackb(message.value)

msgpack/_unpacker.pyx in msgpack._unpacker.unpackb (msgpack/_unpacker.cpp:2143)()

ExtraData: unpack(b) received extra data.

python 3.5，msgpack python
有什么想法吗？

python apache-kafka python-3.x msgpack

来源：https://stackoverflow.com/questions/43010212/msgpack-c-sharp-kafka-consumer-kafka-python-fails-with-extradata-unpack

1条答案

按热度按时间

kyvafyod1#

好吧，如果我使用msgpack pythonhttps://pypi.python.org/pypi/u-msgpack-python 一切正常

In [4]: import umsgpack
In [5]: umsgpack.unpackb(message.value)
Out[5]: 
['00000000-0000-0000-0000-000000000000',
 None,
 '00000000-0000-0000-0000-000000000000',
 None,
 None,
 '00000000-0000-0000-0000-000000000000',
 '',
 1489527866,
 True,
 '3c4d1a52-536c-421a-b258-346b06097fda',
 '1ceb5f07-b62a-4d3b-811a-d2adfce45496',
 '192.168.14.177',
 False,
 'OSXEditor',
 'Mac OS X 10.12.3',
 'c5966702-2936-4028-b911-c417cea9744f',
 0,
 '19fba27e-abf9-4be1-b8c9-eb583f3b3f61',
 5072,
 '87bafec1-5368-4b5c-8368-7309a3e39a80',
 0.0]

赞(0）回复(0）举报 2021-06-07

我来回答

>kafka->consumer(kafka python)失败，并显示extradata:unpack(b)接收到额外数据

1条答案

相关问题

热门标签

最新问答