{"action":"created","issue":{"url":"https://api.github.com/repos/Parsely/pykafka/issues/207","labels_url":"https://api.github.com/repos/Parsely/pykafka/issues/207/labels{/name}","comments_url":"https://api.github.com/repos/Parsely/pykafka/issues/207/comments","events_url":"https://api.github.com/repos/Parsely/pykafka/issues/207/events","html_url":"https://github.com/Parsely/pykafka/issues/207","id":96327586,"number":207,"title":"Kafka balanced consumer reads each character as separate message","user":{"login":"ziky90","id":1810839,"avatar_url":"https://avatars.githubusercontent.com/u/1810839?v=3","gravatar_id":"","url":"https://api.github.com/users/ziky90","html_url":"https://github.com/ziky90","followers_url":"https://api.github.com/users/ziky90/followers","following_url":"https://api.github.com/users/ziky90/following{/other_user}","gists_url":"https://api.github.com/users/ziky90/gists{/gist_id}","starred_url":"https://api.github.com/users/ziky90/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ziky90/subscriptions","organizations_url":"https://api.github.com/users/ziky90/orgs","repos_url":"https://api.github.com/users/ziky90/repos","events_url":"https://api.github.com/users/ziky90/events{/privacy}","received_events_url":"https://api.github.com/users/ziky90/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-07-21T14:20:10Z","updated_at":"2015-07-23T08:01:19Z","closed_at":null,"body":"With respect to the #196 I have updated kafka to version 0.8.2.\r\n\r\nNow it seems that I am experiencing  another problem. My pykafka consumer reads the data from kafka character by character (every character as separate message) instead as a one message.\r\nIn order to be able to read the whole message I need to wrap it to double quotes eg. `\"{\"field\":\"my content\"}\"`\r\n\r\nFor sending the data to kafka I use just command `kafka-console-producer.sh --broker-list localhost:9092 --topic test`\r\n\r\nI would like to ask if someone has already experienced this problem? If so, then what I am possibly doing wrong?\r\n\r\n**EDIT:**\r\nNow I have realised that this error only happens when I am trying to send jsons. Sending normal text messages eg. `hello world` works well.\r\n\r\nAnd I have also experienced the same problem when I am using the `simple_consumer` instead of the `balanced_consumer` "},"comment":{"url":"https://api.github.com/repos/Parsely/pykafka/issues/comments/124012529","html_url":"https://github.com/Parsely/pykafka/issues/207#issuecomment-124012529","issue_url":"https://api.github.com/repos/Parsely/pykafka/issues/207","id":124012529,"user":{"login":"ziky90","id":1810839,"avatar_url":"https://avatars.githubusercontent.com/u/1810839?v=3","gravatar_id":"","url":"https://api.github.com/users/ziky90","html_url":"https://github.com/ziky90","followers_url":"https://api.github.com/users/ziky90/followers","following_url":"https://api.github.com/users/ziky90/following{/other_user}","gists_url":"https://api.github.com/users/ziky90/gists{/gist_id}","starred_url":"https://api.github.com/users/ziky90/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ziky90/subscriptions","organizations_url":"https://api.github.com/users/ziky90/orgs","repos_url":"https://api.github.com/users/ziky90/repos","events_url":"https://api.github.com/users/ziky90/events{/privacy}","received_events_url":"https://api.github.com/users/ziky90/received_events","type":"User","site_admin":false},"created_at":"2015-07-23T08:01:19Z","updated_at":"2015-07-23T08:01:19Z","body":"Hi @emmett9001 \r\n\r\nYes this is exactly the way I am testing it. Except instead of `/opt/kafka-0.8.2.1/bin/kafka-console-producer.sh` I am using `/usr/local/bin/kafka-console-producer.sh`.\r\n\r\nInspecting the folder `/usr/local/bin` I can see kafka version 0.8.2.1"}}