{"action":"created","issue":{"url":"https://api.github.com/repos/Shopify/sarama/issues/741","repository_url":"https://api.github.com/repos/Shopify/sarama","labels_url":"https://api.github.com/repos/Shopify/sarama/issues/741/labels{/name}","comments_url":"https://api.github.com/repos/Shopify/sarama/issues/741/comments","events_url":"https://api.github.com/repos/Shopify/sarama/issues/741/events","html_url":"https://github.com/Shopify/sarama/issues/741","id":174754729,"number":741,"title":"Sarama: disconnected producer stays disconnected","user":{"login":"josselin-c","id":2820724,"avatar_url":"https://avatars.githubusercontent.com/u/2820724?v=3","gravatar_id":"","url":"https://api.github.com/users/josselin-c","html_url":"https://github.com/josselin-c","followers_url":"https://api.github.com/users/josselin-c/followers","following_url":"https://api.github.com/users/josselin-c/following{/other_user}","gists_url":"https://api.github.com/users/josselin-c/gists{/gist_id}","starred_url":"https://api.github.com/users/josselin-c/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/josselin-c/subscriptions","organizations_url":"https://api.github.com/users/josselin-c/orgs","repos_url":"https://api.github.com/users/josselin-c/repos","events_url":"https://api.github.com/users/josselin-c/events{/privacy}","received_events_url":"https://api.github.com/users/josselin-c/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/Shopify/sarama/labels/bug","name":"bug","color":"fc2929"},{"url":"https://api.github.com/repos/Shopify/sarama/labels/needs-more-info","name":"needs-more-info","color":"eb6420"},{"url":"https://api.github.com/repos/Shopify/sarama/labels/producer","name":"producer","color":"009800"}],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":2,"created_at":"2016-09-02T13:02:23Z","updated_at":"2016-09-06T09:50:59Z","closed_at":"2016-09-06T09:50:59Z","body":"##### Versions\r\nSarama Version: 1.9\r\nKafka Version: 0.9\r\nGo Version: 1.6.2\r\n\r\n##### Configuration\r\nDefault sarama config\r\n\r\n##### Logs\r\n[Sarama] 2016/09/01 18:01:51 write tcp 55.66.77.88:56398->11.22.33.44:9092: write: broken pipe\r\n...\r\n[Sarama] 2016/09/02 14:26:46 write tcp 55.66.77.88:56398->11.22.33.44:9092: write: broken pipe\r\n[Sarama] 2016/09/02 14:26:47 write tcp 55.66.77.88:56398->11.22.33.44:9092: write: broken pipe\r\n\r\n##### Problem Description\r\nI'm using a SyncProducer, after some connectivity issue the producer can't produce to kafka anymore and always return an error, even after the connectivity to kafka is restored.\r\nIs this a scenario my code should handle: close the current consumer, create a new one? Or should this be handled by the producer?\r\n\r\nThanks\r\n"},"comment":{"url":"https://api.github.com/repos/Shopify/sarama/issues/comments/244903347","html_url":"https://github.com/Shopify/sarama/issues/741#issuecomment-244903347","issue_url":"https://api.github.com/repos/Shopify/sarama/issues/741","id":244903347,"user":{"login":"josselin-c","id":2820724,"avatar_url":"https://avatars.githubusercontent.com/u/2820724?v=3","gravatar_id":"","url":"https://api.github.com/users/josselin-c","html_url":"https://github.com/josselin-c","followers_url":"https://api.github.com/users/josselin-c/followers","following_url":"https://api.github.com/users/josselin-c/following{/other_user}","gists_url":"https://api.github.com/users/josselin-c/gists{/gist_id}","starred_url":"https://api.github.com/users/josselin-c/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/josselin-c/subscriptions","organizations_url":"https://api.github.com/users/josselin-c/orgs","repos_url":"https://api.github.com/users/josselin-c/repos","events_url":"https://api.github.com/users/josselin-c/events{/privacy}","received_events_url":"https://api.github.com/users/josselin-c/received_events","type":"User","site_admin":false},"created_at":"2016-09-06T09:50:59Z","updated_at":"2016-09-06T09:50:59Z","body":"Okay, after doing some tests, I can attest that production seem to restart and indeed is resilient to disconnection / network errors.\r\n\r\nI tried to find were the error I got was coming from, I think it comes from the sarama-cluster library which uses the Sarama Logger to log its own errors (and doesn't add a \"cluster\" prefix or something) which confused me as I though the error was in Sarama.\r\nI don't know why my code stopped producing but it seem unlikely to be because of the sarama producer."}}
{"actor":{"display_login":"josselin-c"}}