{"action":"opened","issue":{"url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/140","labels_url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/140/labels{/name}","comments_url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/140/comments","events_url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/140/events","html_url":"https://github.com/stealthly/go_kafka_client/issues/140","id":96904793,"number":140,"title":"consumer.Close() never finishes and always panics","user":{"login":"davidzeng","id":1017876,"avatar_url":"https://avatars.githubusercontent.com/u/1017876?v=3","gravatar_id":"","url":"https://api.github.com/users/davidzeng","html_url":"https://github.com/davidzeng","followers_url":"https://api.github.com/users/davidzeng/followers","following_url":"https://api.github.com/users/davidzeng/following{/other_user}","gists_url":"https://api.github.com/users/davidzeng/gists{/gist_id}","starred_url":"https://api.github.com/users/davidzeng/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/davidzeng/subscriptions","organizations_url":"https://api.github.com/users/davidzeng/orgs","repos_url":"https://api.github.com/users/davidzeng/repos","events_url":"https://api.github.com/users/davidzeng/events{/privacy}","received_events_url":"https://api.github.com/users/davidzeng/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":0,"created_at":"2015-07-23T21:02:21Z","updated_at":"2015-07-23T21:02:21Z","closed_at":null,"body":"I'm trying to Close() the consumer under circumstances, but whenever I call the Close() function, the worker manager never seems to finish. \r\n\r\n```13:39:52.1 | 2015-07-23/13:39:52 [INFO] [ConsumerFetcherRoutine-TTV-0582.local:e989b4a8-8365-45f3-e3b1-eaf942271e68-0] Closing fetcher\r\n13:39:52.1 | 2015-07-23/13:39:52 [INFO] [ConsumerFetcherRoutine-TTV-0582.local:e989b4a8-8365-45f3-e3b1-eaf942271e68-0] Stopped fetcher\r\n13:39:52.1 | 2015-07-23/13:39:52 [INFO] [TTV-0582.local:e989b4a8-8365-45f3-e3b1-eaf942271e68-manager] Successfully closed all fetcher manager routines\r\n13:39:52.1 | 2015-07-23/13:39:52 [INFO] [TTV-0582.local:e989b4a8-8365-45f3-e3b1-eaf942271e68] Stopping worker manager...\r\n13:44:52.1 | panic: Graceful shutdown failed\r\n```\r\n\r\nAre there pre-requisites that need to be fulfilled before calling the function? I've tried upping the timeout to 5 minutes, but it still does nothing."}}