{"action":"created","issue":{"url":"https://api.github.com/repos/Parsely/pykafka/issues/571","repository_url":"https://api.github.com/repos/Parsely/pykafka","labels_url":"https://api.github.com/repos/Parsely/pykafka/issues/571/labels{/name}","comments_url":"https://api.github.com/repos/Parsely/pykafka/issues/571/comments","events_url":"https://api.github.com/repos/Parsely/pykafka/issues/571/events","html_url":"https://github.com/Parsely/pykafka/issues/571","id":160798574,"number":571,"title":"pykafka.ownedBroker.queue_reader in pyspark","user":{"login":"christianbo","id":14797479,"avatar_url":"https://avatars.githubusercontent.com/u/14797479?v=3","gravatar_id":"","url":"https://api.github.com/users/christianbo","html_url":"https://github.com/christianbo","followers_url":"https://api.github.com/users/christianbo/followers","following_url":"https://api.github.com/users/christianbo/following{/other_user}","gists_url":"https://api.github.com/users/christianbo/gists{/gist_id}","starred_url":"https://api.github.com/users/christianbo/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/christianbo/subscriptions","organizations_url":"https://api.github.com/users/christianbo/orgs","repos_url":"https://api.github.com/users/christianbo/repos","events_url":"https://api.github.com/users/christianbo/events{/privacy}","received_events_url":"https://api.github.com/users/christianbo/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/Parsely/pykafka/labels/hazy","name":"hazy","color":"fbca04"},{"url":"https://api.github.com/repos/Parsely/pykafka/labels/question","name":"question","color":"cc317c"}],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2016-06-17T02:10:14Z","updated_at":"2016-06-17T12:03:31Z","closed_at":null,"body":"when using producer of pykafka in pyspark, i get a problem:\r\n```\r\nException in thread 5 : pykafka.ownedBroker.queue_reader for broker 55:\r\nTraceback(most recent call last):\r\nFile\"/usr/locla/lib/python2.7/threading.py\". line 810, in __bootstrap innerself.run()\r\nFile\"/usr/locla/lib/python2.7/threading.py\".line 763 in runself.__target(*self.__args,**self.__kwargs)\r\nFile \"/usr/local/lib/python2.7/site-packages/pykafka/producer.py\".line 529, in queue_reader \r\nself.producer._worker_exception:sys.exc_info()\r\nReference Error: weakly-referenced object no longer exists\r\n```\r\n\r\nI create producer in each mapPartitions, there are 4 partitions,so  I got 4 printings as above，and the program pending, not exist,please help \r\n\r\n\r\n**PyKafka version**: 2.4\r\n**Kafka version**:\r\n"},"comment":{"url":"https://api.github.com/repos/Parsely/pykafka/issues/comments/226752022","html_url":"https://github.com/Parsely/pykafka/issues/571#issuecomment-226752022","issue_url":"https://api.github.com/repos/Parsely/pykafka/issues/571","id":226752022,"user":{"login":"emmett9001","id":723615,"avatar_url":"https://avatars.githubusercontent.com/u/723615?v=3","gravatar_id":"","url":"https://api.github.com/users/emmett9001","html_url":"https://github.com/emmett9001","followers_url":"https://api.github.com/users/emmett9001/followers","following_url":"https://api.github.com/users/emmett9001/following{/other_user}","gists_url":"https://api.github.com/users/emmett9001/gists{/gist_id}","starred_url":"https://api.github.com/users/emmett9001/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/emmett9001/subscriptions","organizations_url":"https://api.github.com/users/emmett9001/orgs","repos_url":"https://api.github.com/users/emmett9001/repos","events_url":"https://api.github.com/users/emmett9001/events{/privacy}","received_events_url":"https://api.github.com/users/emmett9001/received_events","type":"User","site_admin":false},"created_at":"2016-06-17T12:03:31Z","updated_at":"2016-06-17T12:03:31Z","body":"Hi @christianbo, thanks for filing this. Could you please include an example of the code you're using to set up and use your `Producer`? My guess is that you're attempting to produce without keeping a reference to the `Topic`."}}
{"actor":{"display_login":"emmett9001"}}