{"action":"created","issue":{"url":"https://api.github.com/repos/nsqio/nsq/issues/1041","repository_url":"https://api.github.com/repos/nsqio/nsq","labels_url":"https://api.github.com/repos/nsqio/nsq/issues/1041/labels{/name}","comments_url":"https://api.github.com/repos/nsqio/nsq/issues/1041/comments","events_url":"https://api.github.com/repos/nsqio/nsq/issues/1041/events","html_url":"https://github.com/nsqio/nsq/issues/1041","id":329696476,"node_id":"MDU6SXNzdWUzMjk2OTY0NzY=","number":1041,"title":"nsqd: consumer can not consume sometimes","user":{"login":"czh0318","id":8529883,"node_id":"MDQ6VXNlcjg1Mjk4ODM=","avatar_url":"https://avatars1.githubusercontent.com/u/8529883?v=4","gravatar_id":"","url":"https://api.github.com/users/czh0318","html_url":"https://github.com/czh0318","followers_url":"https://api.github.com/users/czh0318/followers","following_url":"https://api.github.com/users/czh0318/following{/other_user}","gists_url":"https://api.github.com/users/czh0318/gists{/gist_id}","starred_url":"https://api.github.com/users/czh0318/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/czh0318/subscriptions","organizations_url":"https://api.github.com/users/czh0318/orgs","repos_url":"https://api.github.com/users/czh0318/repos","events_url":"https://api.github.com/users/czh0318/events{/privacy}","received_events_url":"https://api.github.com/users/czh0318/received_events","type":"User","site_admin":false},"labels":[{"id":4890526,"node_id":"MDU6TGFiZWw0ODkwNTI2","url":"https://api.github.com/repos/nsqio/nsq/labels/question","name":"question","color":"f7c6c7","default":true}],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":4,"created_at":"2018-06-06T03:20:47Z","updated_at":"2018-11-13T06:20:22Z","closed_at":"2018-06-06T15:37:22Z","author_association":"NONE","body":"Hi， I used nsq as one topic and three channel on consumer client. Most of time, it work fine. However, sometimes it doesn't work good on one channel.  Below is the log, topic name is credit-data-topic and channel name is risk.\r\n```\r\n2018/06/05 19:03:15 WRN    2 [credit-data-topic/risk] msg 09d037dccf862000 attempted 6 times, giving up\r\n2018/06/05 19:03:15 ERR    2 [credit-data-topic/risk] (127.0.0.1:4150) IO error - write tcp 127.0.0.1:56966->127.0.0.1:4150: write: broken pipe\r\n2018/06/05 19:03:15 ERR    2 [credit-data-topic/risk] (127.0.0.1:4150) IO error - write tcp 127.0.0.1:56966->127.0.0.1:4150: write: broken pipe\r\n2018/06/05 19:03:15 WRN    2 [credit-data-topic/risk] (127.0.0.1:4150) delaying close, 2 outstanding messages\r\n2018/06/05 19:03:15 INF    2 [credit-data-topic/risk] (127.0.0.1:4150) readLoop exiting\r\n2018/06/05 19:03:15 ERR    2 [credit-data-topic/risk] (127.0.0.1:4150) IO error - write tcp 127.0.0.1:56966->127.0.0.1:4150: write: broken pipe\r\n2018/06/05 19:03:15 ERR    2 [credit-data-topic/risk] (127.0.0.1:4150) error sending command FIN 09d037dccf862000 - write tcp 127.0.0.1:56966->127.0.0.1:4150: write: broken pipe\r\n2018/06/05 19:03:15 INF    2 [credit-data-topic/risk] (127.0.0.1:4150) beginning close\r\n2018/06/05 19:03:15 INF    2 [credit-data-topic/risk] (127.0.0.1:4150) breaking out of writeLoop\r\n2018/06/05 19:03:15 INF    2 [credit-data-topic/risk] (127.0.0.1:4150) writeLoop exiting\r\n2018/06/05 19:03:15 INF    2 [credit-data-topic/risk] (127.0.0.1:4150) finished draining, cleanup exiting\r\n2018/06/05 19:03:15 INF    2 [credit-data-topic/risk] (127.0.0.1:4150) clean close complete\r\n2018/06/05 19:03:15 WRN    2 [credit-data-topic/risk] there are 0 connections left alive\r\n2018/06/05 19:03:15 INF    2 [credit-data-topic/risk] (127.0.0.1:4150) re-connecting in 1m0s\r\n2018/06/05 19:04:15 INF    2 [credit-data-topic/risk] (127.0.0.1:4150) connecting to nsqd\r\n2018/06/05 19:04:15 WRN    2 [credit-data-topic/risk] msg 09d037dccf862000 attempted 7 times, giving up \r\n```\r\nThank you very much for your help."},"comment":{"url":"https://api.github.com/repos/nsqio/nsq/issues/comments/438151208","html_url":"https://github.com/nsqio/nsq/issues/1041#issuecomment-438151208","issue_url":"https://api.github.com/repos/nsqio/nsq/issues/1041","id":438151208,"node_id":"MDEyOklzc3VlQ29tbWVudDQzODE1MTIwOA==","user":{"login":"ploxiln","id":649835,"node_id":"MDQ6VXNlcjY0OTgzNQ==","avatar_url":"https://avatars2.githubusercontent.com/u/649835?v=4","gravatar_id":"","url":"https://api.github.com/users/ploxiln","html_url":"https://github.com/ploxiln","followers_url":"https://api.github.com/users/ploxiln/followers","following_url":"https://api.github.com/users/ploxiln/following{/other_user}","gists_url":"https://api.github.com/users/ploxiln/gists{/gist_id}","starred_url":"https://api.github.com/users/ploxiln/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ploxiln/subscriptions","organizations_url":"https://api.github.com/users/ploxiln/orgs","repos_url":"https://api.github.com/users/ploxiln/repos","events_url":"https://api.github.com/users/ploxiln/events{/privacy}","received_events_url":"https://api.github.com/users/ploxiln/received_events","type":"User","site_admin":false},"created_at":"2018-11-13T06:20:22Z","updated_at":"2018-11-13T06:20:22Z","author_association":"CONTRIBUTOR","body":"I think the problem you run into would be in the client library. My first guess is that setting concurrency equal to max_in_flight may work-around the problem. If you have follow-up information (client library version) and questions please post on the mailing list https://groups.google.com/forum/#!forum/nsq-users"}}
{"actor":{"display_login":"ploxiln"}}