{"action":"closed","issue":{"url":"https://api.github.com/repos/Parsely/pykafka/issues/791","repository_url":"https://api.github.com/repos/Parsely/pykafka","labels_url":"https://api.github.com/repos/Parsely/pykafka/issues/791/labels{/name}","comments_url":"https://api.github.com/repos/Parsely/pykafka/issues/791/comments","events_url":"https://api.github.com/repos/Parsely/pykafka/issues/791/events","html_url":"https://github.com/Parsely/pykafka/issues/791","id":317448337,"number":791,"title":"consumer rate decreasing","user":{"login":"arita37","id":18707623,"avatar_url":"https://avatars3.githubusercontent.com/u/18707623?v=4","gravatar_id":"","url":"https://api.github.com/users/arita37","html_url":"https://github.com/arita37","followers_url":"https://api.github.com/users/arita37/followers","following_url":"https://api.github.com/users/arita37/following{/other_user}","gists_url":"https://api.github.com/users/arita37/gists{/gist_id}","starred_url":"https://api.github.com/users/arita37/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/arita37/subscriptions","organizations_url":"https://api.github.com/users/arita37/orgs","repos_url":"https://api.github.com/users/arita37/repos","events_url":"https://api.github.com/users/arita37/events{/privacy}","received_events_url":"https://api.github.com/users/arita37/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-04-25T01:23:18Z","updated_at":"2018-04-25T16:27:34Z","closed_at":"2018-04-25T16:27:34Z","author_association":"NONE","body":"Hello,\r\n\r\nWe are using normal code as follow :\r\nhttps://github.com/Parsely/pykafka/issues/781\r\n\r\n\r\n```\r\nconsumer = topic.get_balanced_consumer()  # all default parameters...  3 balanced consumer\r\nwhile True:\r\n    try:\r\n        for message in consumer:\r\n              ii+=1\r\n              msgraw = consumer.consume()\r\n              msg    = msgraw.value.decode('utf8')\r\n              msg    = json.loads(msg)   \r\n              .... #very fast process\r\n              producer.produce(json_data)\r\n   except Exception as e : \r\n               print(e)\r\n```\r\n\r\n\r\nWhat happens :   \r\n   0 min - 5 mins :   Input flow is  same Kafka server (test server with fixed flow).\r\n   After  5 mins:      Almost half of the expected.\r\n\r\n1) Just wondering if you have done some tests to see the consuming flow is matching kafka output ?\r\n\r\n2)  Is 1/2 of the flow matching anything in consumer config ?\r\n\r\nCan we re-open this issue ?\r\n\r\n\r\n\r\n"}}
{"actor":{"display_login":"emmett9001"}}