Title: unpack buffer from python's msgpack API returned unexpected '-3' · Issue #48 · msgpack/msgpack-node · GitHub
Open Graph Title: unpack buffer from python's msgpack API returned unexpected '-3' · Issue #48 · msgpack/msgpack-node
X Title: unpack buffer from python's msgpack API returned unexpected '-3' · Issue #48 · msgpack/msgpack-node
Description: Hi authors, I would like to seek for some assistance of the following issue: I've got a python program to packb msgpack.packb into a kafka flow and was able to consume the flow. What I did with each message is to buffer.from the message ...
Open Graph Description: Hi authors, I would like to seek for some assistance of the following issue: I've got a python program to packb msgpack.packb into a kafka flow and was able to consume the flow. What I did with eac...
X Description: Hi authors, I would like to seek for some assistance of the following issue: I've got a python program to packb msgpack.packb into a kafka flow and was able to consume the flow. What I did with...
Opengraph URL: https://github.com/msgpack/msgpack-node/issues/48
X: @github
Domain: patch-diff.githubusercontent.com
{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"unpack buffer from python's msgpack API returned unexpected '-3'","articleBody":"Hi authors, I would like to seek for some assistance of the following issue:\r\n\r\nI've got a python program to packb [msgpack.packb](https://msgpack-python.readthedocs.io/en/latest/api.html) into a kafka flow and was able to consume the flow. What I did with each message is to buffer.from the message and try to unpack on the node end - instead of getting the object I got '-3' as result.\r\n\r\nBelow I wrote some logic for troubleshooting:\r\n```\r\n 19 consumer.on('message', function (message) {\r\n 20 const buf = Buffer.from(message[\"value\"], 'binary');\r\n 21 console.log(\"=========================================================================================================================\")\r\n 22 console.log('The buffer version of the message:')\r\n 23 console.log(buf)\r\n 24 console.log('The unpack version of the message:')\r\n 25 console.log(msgpack.unpack(buf))\r\n 26 console.log('The string version of the message:')\r\n 27 console.log(message[\"value\"])\r\n 28 console.log('The binary version of the message:')\r\n 29 console.log(buf.toString('hex').match(/../g).join(' '))\r\n 30 });\r\n```\r\n\r\n\r\nAnd below is what the script returns:\r\n\r\n```\r\n=========================================================================================================================\r\nThe buffer version of the message:\r\n\u003cBuffer fd fd 49 6e 73 74 61 6e 63 65 fd 48 4b 4f 43 47 5f 50 fd 53 65 6e 74 54 69 6d 65 fd 32 30 31 39 30 32 30 31 2d 31 30 3a 35 30 3a 30 39 2e 38 31 34 34 ... \u003e\r\nThe unpack version of the message:\r\n-3\r\nThe string version of the message:\r\n��Instance�HKOCG_P�SentTime�20190201-10:50:09.814407�Severity�W�AlertMessage��HKG OCG1 [Disconnected:0 R8802:8802:8555:0:0:0 L0 S6616:6616:6616:6363:6363:6363:0]: connect(10.1.93.17:50036): Connection refused�Acked�N\r\nThe binary version of the message:\r\nfd fd 49 6e 73 74 61 6e 63 65 fd 48 4b 4f 43 47 5f 50 fd 53 65 6e 74 54 69 6d 65 fd 32 30 31 39 30 32 30 31 2d 31 30 3a 35 30 3a 30 39 2e 38 31 34 34 30 37 fd 53 65 76 65 72 69 74 79 fd 57 fd 41 6c 65 72 74 4d 65 73 73 61 67 65 fd 00 fd 48 4b 47 20 4f 43 47 31 20 5b 44 69 73 63 6f 6e 6e 65 63 74 65 64 3a 30 20 52 38 38 30 32 3a 38 38 30 32 3a 38 35 35 35 3a 30 3a 30 3a 30 20 4c 30 20 53 36 36 31 36 3a 36 36 31 36 3a 36 36 31 36 3a 36 33 36 33 3a 36 33 36 33 3a 36 33 36 33 3a 30 5d 3a 20 63 6f 6e 6e 65 63 74 28 31 30 2e 31 2e 39 33 2e 31 37 3a 35 30 30 33 36 29 3a 20 43 6f 6e 6e 65 63 74 69 6f 6e 20 72 65 66 75 73 65 64 fd 41 63 6b 65 64 fd 4e\r\n```\r\n\r\n\r\nWhat is wrong during the convert in the function? \r\nThanks","author":{"url":"https://github.com/ctlkkc","@type":"Person","name":"ctlkkc"},"datePublished":"2019-02-05T03:02:10.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/48/msgpack-node/issues/48"}
| route-pattern | /_view_fragments/issues/show/:user_id/:repository/:id/issue_layout(.:format) |
| route-controller | voltron_issues_fragments |
| route-action | issue_layout |
| fetch-nonce | v2:00cffbca-71cb-6705-78ca-f4a1e2682744 |
| current-catalog-service-hash | 81bb79d38c15960b92d99bca9288a9108c7a47b18f2423d0f6438c5b7bcd2114 |
| request-id | E70A:1DFA96:E387B:121307:6990578B |
| html-safe-nonce | 1136649aba205aedb6c2995e3f5c254b77eb8598b02ed0bf233f68a827bcc728 |
| visitor-payload | eyJyZWZlcnJlciI6IiIsInJlcXVlc3RfaWQiOiJFNzBBOjFERkE5NjpFMzg3QjoxMjEzMDc6Njk5MDU3OEIiLCJ2aXNpdG9yX2lkIjoiNjkwNDI4NTk4MzA4NjIzNzU3OSIsInJlZ2lvbl9lZGdlIjoiaWFkIiwicmVnaW9uX3JlbmRlciI6ImlhZCJ9 |
| visitor-hmac | 7a649ec4a0bdce1424539c684bb9991b7bc1085ec61ed4c172e1f26b7a8b0360 |
| hovercard-subject-tag | issue:406611427 |
| github-keyboard-shortcuts | repository,issues,copilot |
| google-site-verification | Apib7-x98H0j5cPqHWwSMm6dNU4GmODRoqxLiDzdx9I |
| octolytics-url | https://collector.github.com/github/collect |
| analytics-location | / |
| fb:app_id | 1401488693436528 |
| apple-itunes-app | app-id=1477376905, app-argument=https://github.com/_view_fragments/issues/show/msgpack/msgpack-node/48/issue_layout |
| twitter:image | https://opengraph.githubassets.com/5c14a470ae83de66e792913716fa7598a9cb4693ec92445a030b95abf5eb4a2d/msgpack/msgpack-node/issues/48 |
| twitter:card | summary_large_image |
| og:image | https://opengraph.githubassets.com/5c14a470ae83de66e792913716fa7598a9cb4693ec92445a030b95abf5eb4a2d/msgpack/msgpack-node/issues/48 |
| og:image:alt | Hi authors, I would like to seek for some assistance of the following issue: I've got a python program to packb msgpack.packb into a kafka flow and was able to consume the flow. What I did with eac... |
| og:image:width | 1200 |
| og:image:height | 600 |
| og:site_name | GitHub |
| og:type | object |
| og:author:username | ctlkkc |
| hostname | github.com |
| expected-hostname | github.com |
| None | 42c603b9d642c4a9065a51770f75e5e27132fef0e858607f5c9cb7e422831a7b |
| turbo-cache-control | no-preview |
| go-import | github.com/msgpack/msgpack-node git https://github.com/msgpack/msgpack-node.git |
| octolytics-dimension-user_id | 198264 |
| octolytics-dimension-user_login | msgpack |
| octolytics-dimension-repository_id | 7430783 |
| octolytics-dimension-repository_nwo | msgpack/msgpack-node |
| octolytics-dimension-repository_public | true |
| octolytics-dimension-repository_is_fork | false |
| octolytics-dimension-repository_network_root_id | 7430783 |
| octolytics-dimension-repository_network_root_nwo | msgpack/msgpack-node |
| turbo-body-classes | logged-out env-production page-responsive |
| disable-turbo | false |
| browser-stats-url | https://api.github.com/_private/browser/stats |
| browser-errors-url | https://api.github.com/_private/browser/errors |
| release | 3b33c5aedc9808f45bc5fcf0b1e4404cf749dac7 |
| ui-target | full |
| theme-color | #1e2327 |
| color-scheme | light dark |
Links:
Viewport: width=device-width