{"action":"created","issue":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/719","repository_url":"https://api.github.com/repos/edenhill/librdkafka","labels_url":"https://api.github.com/repos/edenhill/librdkafka/issues/719/labels{/name}","comments_url":"https://api.github.com/repos/edenhill/librdkafka/issues/719/comments","events_url":"https://api.github.com/repos/edenhill/librdkafka/issues/719/events","html_url":"https://github.com/edenhill/librdkafka/issues/719","id":163980930,"number":719,"title":"Is there any way to return from the producer client when Kafka crashes while sending message to it?","user":{"login":"nxgyzxw","id":12147099,"avatar_url":"https://avatars.githubusercontent.com/u/12147099?v=3","gravatar_id":"","url":"https://api.github.com/users/nxgyzxw","html_url":"https://github.com/nxgyzxw","followers_url":"https://api.github.com/users/nxgyzxw/followers","following_url":"https://api.github.com/users/nxgyzxw/following{/other_user}","gists_url":"https://api.github.com/users/nxgyzxw/gists{/gist_id}","starred_url":"https://api.github.com/users/nxgyzxw/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/nxgyzxw/subscriptions","organizations_url":"https://api.github.com/users/nxgyzxw/orgs","repos_url":"https://api.github.com/users/nxgyzxw/repos","events_url":"https://api.github.com/users/nxgyzxw/events{/privacy}","received_events_url":"https://api.github.com/users/nxgyzxw/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-07-06T01:33:34Z","updated_at":"2016-07-06T01:44:10Z","closed_at":null,"body":"Description\r\n===========\r\nDear Magnus,\r\nWhen firstly sending messages to Kafka(only 1 broker), everything works fine. But during the transmission, the Kafka server somehow breaks down, and the producer client just hangs there so I can't start the next round transmission.\r\n\r\nIn the destructor function, I ues:\r\n\tif (producerHandle)\r\n\t{\r\n\t\t    while(producerHandle->outq_len() > 0)\r\n    \t\t{\r\n    \t\t\t    continue;\r\n\t\t    }\r\n    \t\tdelete producerHandle;\r\n\t}\r\n\r\nPerhaps it's because outq_len() is always greater than 0 ?  So this is a endless loop?\r\nIn the CONFIGURATION.md, I found some TimeOut Settings, and I think messages buffered in the local que should timed out somehow?\r\n\r\nPlease point out a solution to me, thank you .\r\n\r\n\r\n\r\nChecklist\r\n=========\r\nPlease provide the following information:\r\n\r\n - [ 0.9.0.1] librdkafka version (release number or git tag):\r\n - [ 0.8.2.1] Apache Kafka version: \r\n - [ ] librdkafka client configuration:\r\n - [ RedHat] Operating system:\r\n - [ ] Using the legacy Consumer\r\n - [ ] Using the high-level KafkaConsumer\r\n - [ ] Provide logs (with `debug=..` as necessary) from librdkafka\r\n - [ ] Provide broker log excerpts\r\n - [ ] Critical issue\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/comments/230650944","html_url":"https://github.com/edenhill/librdkafka/issues/719#issuecomment-230650944","issue_url":"https://api.github.com/repos/edenhill/librdkafka/issues/719","id":230650944,"user":{"login":"nxgyzxw","id":12147099,"avatar_url":"https://avatars.githubusercontent.com/u/12147099?v=3","gravatar_id":"","url":"https://api.github.com/users/nxgyzxw","html_url":"https://github.com/nxgyzxw","followers_url":"https://api.github.com/users/nxgyzxw/followers","following_url":"https://api.github.com/users/nxgyzxw/following{/other_user}","gists_url":"https://api.github.com/users/nxgyzxw/gists{/gist_id}","starred_url":"https://api.github.com/users/nxgyzxw/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/nxgyzxw/subscriptions","organizations_url":"https://api.github.com/users/nxgyzxw/orgs","repos_url":"https://api.github.com/users/nxgyzxw/repos","events_url":"https://api.github.com/users/nxgyzxw/events{/privacy}","received_events_url":"https://api.github.com/users/nxgyzxw/received_events","type":"User","site_admin":false},"created_at":"2016-07-06T01:44:10Z","updated_at":"2016-07-06T01:44:10Z","body":"I found some Info in #426 . Still this is the solution ?"}}
{"actor":{"display_login":"nxgyzxw"}}