{"action":"closed","issue":{"url":"https://api.github.com/repos/mailgun/kafka-pixy/issues/76","repository_url":"https://api.github.com/repos/mailgun/kafka-pixy","labels_url":"https://api.github.com/repos/mailgun/kafka-pixy/issues/76/labels{/name}","comments_url":"https://api.github.com/repos/mailgun/kafka-pixy/issues/76/comments","events_url":"https://api.github.com/repos/mailgun/kafka-pixy/issues/76/events","html_url":"https://github.com/mailgun/kafka-pixy/issues/76","id":175732162,"number":76,"title":"buffer overflow","user":{"login":"slava-vishnyakov","id":817931,"avatar_url":"https://avatars.githubusercontent.com/u/817931?v=3","gravatar_id":"","url":"https://api.github.com/users/slava-vishnyakov","html_url":"https://github.com/slava-vishnyakov","followers_url":"https://api.github.com/users/slava-vishnyakov/followers","following_url":"https://api.github.com/users/slava-vishnyakov/following{/other_user}","gists_url":"https://api.github.com/users/slava-vishnyakov/gists{/gist_id}","starred_url":"https://api.github.com/users/slava-vishnyakov/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/slava-vishnyakov/subscriptions","organizations_url":"https://api.github.com/users/slava-vishnyakov/orgs","repos_url":"https://api.github.com/users/slava-vishnyakov/repos","events_url":"https://api.github.com/users/slava-vishnyakov/events{/privacy}","received_events_url":"https://api.github.com/users/slava-vishnyakov/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/mailgun/kafka-pixy/labels/question","name":"question","color":"cc317c"}],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":5,"created_at":"2016-09-08T11:42:02Z","updated_at":"2016-09-10T05:39:02Z","closed_at":"2016-09-10T05:39:02Z","body":"```\r\n#!/bin/bash\r\n\r\n## Push test data\r\n\r\nfunction pushit() {\r\n    curl --silent -X POST \"http://localhost:19092/topics/foo/messages?sync\" -H \"Content-Type: text/plain\" -d \"blah blah blah {}\"\r\n}\r\nexport -f pushit\r\ntime (seq 1000 | parallel -j100 pushit)\r\n\r\n## Reset\r\n\r\ncurl -X POST -H'Content-Type: application/json' -d'[{\"partition\":0,\"offset\":0}]' 'http://localhost:19092/topics/foo/offsets?group=bar'\r\necho\r\nsleep 10\r\n\r\n## Pull\r\n\r\nfunction pullit() {\r\n    curl -G --silent 'http://localhost:19092/topics/foo/messages?group=bar' | tr \"\\n\" \" \"\r\n    echo\r\n}\r\nexport -f pullit\r\ntime (seq 1000 | parallel -j100 pullit)\r\n\r\n```\r\n\r\nSo, I'm running then the \"pull\" step separately (I'm trying to pull the data from Kafka-Pixy with 100 parallel readers) and sometimes I get this:\r\n\r\n```\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n{   \"error\": \"\\u003c/cons[0]/G:bar[12]/T:foo[0]\\u003e buffer overflow\" }\r\n```\r\n\r\nas a response.\r\n"}}
{"actor":{"display_login":"slava-vishnyakov"}}