{"action":"closed","issue":{"url":"https://api.github.com/repos/Parsely/pykafka/issues/375","labels_url":"https://api.github.com/repos/Parsely/pykafka/issues/375/labels{/name}","comments_url":"https://api.github.com/repos/Parsely/pykafka/issues/375/comments","events_url":"https://api.github.com/repos/Parsely/pykafka/issues/375/events","html_url":"https://github.com/Parsely/pykafka/issues/375","id":119569417,"number":375,"title":"[pykafak/test/utils.py] KafkaInstance doesn't support the current Producer implementation","user":{"login":"rogaha","id":4483394,"avatar_url":"https://avatars.githubusercontent.com/u/4483394?v=3","gravatar_id":"","url":"https://api.github.com/users/rogaha","html_url":"https://github.com/rogaha","followers_url":"https://api.github.com/users/rogaha/followers","following_url":"https://api.github.com/users/rogaha/following{/other_user}","gists_url":"https://api.github.com/users/rogaha/gists{/gist_id}","starred_url":"https://api.github.com/users/rogaha/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/rogaha/subscriptions","organizations_url":"https://api.github.com/users/rogaha/orgs","repos_url":"https://api.github.com/users/rogaha/repos","events_url":"https://api.github.com/users/rogaha/events{/privacy}","received_events_url":"https://api.github.com/users/rogaha/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":{"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},"milestone":null,"comments":2,"created_at":"2015-11-30T20:06:52Z","updated_at":"2015-11-30T20:28:59Z","closed_at":"2015-11-30T20:28:59Z","body":"<pre>\r\nIn [1]: from pykafka.producer import Producer\r\nIn [2]: from pykafka.test.utils import get_cluster, stop_cluster\r\nIn [3]: cluster = get_cluster()\r\nIn [4]: cluster.create_topic('test', 2, 3)\r\nIn [5]: client = KafkaClient(cluster.brokers)\r\nIn [6]: from pykafka.client import KafkaClient\r\nIn [7]: client = KafkaClient(cluster.brokers)\r\nIn [8]: producer = Producer(cluster, client.topics['test'])\r\n---------------------------------------------------------------------------\r\nAttributeError                            Traceback (most recent call last)\r\n<ipython-input-9-41cb2de6f39c> in <module>()\r\n----> 1 producer = Producer(cluster, client.topics['test'])\r\n\r\n/Users/rogaha/.virtualenvs/hydra/lib/python2.7/site-packages/pykafka/producer.pyc in __init__(self, cluster, topic, partitioner, compression, max_retries, retry_backoff_ms, required_acks, ack_timeout_ms, max_queued_messages, min_queued_messages, linger_ms, block_on_queue_full, sync)\r\n    138         self._owned_brokers = None\r\n    139         self._running = False\r\n--> 140         self._update_lock = self._cluster.handler.Lock()\r\n    141         self.start()\r\n    142\r\n\r\nAttributeError: 'KafkaInstance' object has no attribute 'handler'\r\n</pre>"}}