{"action":"created","issue":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/447","labels_url":"https://api.github.com/repos/edenhill/librdkafka/issues/447/labels{/name}","comments_url":"https://api.github.com/repos/edenhill/librdkafka/issues/447/comments","events_url":"https://api.github.com/repos/edenhill/librdkafka/issues/447/events","html_url":"https://github.com/edenhill/librdkafka/issues/447","id":121649007,"number":447,"title":"Lack of functionality of recovery from failed connection to Kafka brokers","user":{"login":"microwish","id":4253329,"avatar_url":"https://avatars.githubusercontent.com/u/4253329?v=3","gravatar_id":"","url":"https://api.github.com/users/microwish","html_url":"https://github.com/microwish","followers_url":"https://api.github.com/users/microwish/followers","following_url":"https://api.github.com/users/microwish/following{/other_user}","gists_url":"https://api.github.com/users/microwish/gists{/gist_id}","starred_url":"https://api.github.com/users/microwish/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/microwish/subscriptions","organizations_url":"https://api.github.com/users/microwish/orgs","repos_url":"https://api.github.com/users/microwish/repos","events_url":"https://api.github.com/users/microwish/events{/privacy}","received_events_url":"https://api.github.com/users/microwish/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-12-11T06:41:14Z","updated_at":"2015-12-11T07:56:25Z","closed_at":null,"body":"Scenario:\r\non Kafka client machine:\r\nrd_kafka_produce() failed with errno ENOBUFS, while queue.buffering.max.messages is set to 500000 which is large enough;\r\ndr_msg_cb reported error string \"Local: Message timed out\";\r\n\r\non Kafka broker machine:\r\nINFO Closing socket connection to /192.168.152.224. (kafka.network.Processor)\r\n\r\nHowever, librdkafka isn't aware of the unexpected failure of connection and cannot recover from that.\r\n\r\nIs there any configuration or something the like for this scenario?"},"comment":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/comments/163868570","html_url":"https://github.com/edenhill/librdkafka/issues/447#issuecomment-163868570","issue_url":"https://api.github.com/repos/edenhill/librdkafka/issues/447","id":163868570,"user":{"login":"microwish","id":4253329,"avatar_url":"https://avatars.githubusercontent.com/u/4253329?v=3","gravatar_id":"","url":"https://api.github.com/users/microwish","html_url":"https://github.com/microwish","followers_url":"https://api.github.com/users/microwish/followers","following_url":"https://api.github.com/users/microwish/following{/other_user}","gists_url":"https://api.github.com/users/microwish/gists{/gist_id}","starred_url":"https://api.github.com/users/microwish/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/microwish/subscriptions","organizations_url":"https://api.github.com/users/microwish/orgs","repos_url":"https://api.github.com/users/microwish/repos","events_url":"https://api.github.com/users/microwish/events{/privacy}","received_events_url":"https://api.github.com/users/microwish/received_events","type":"User","site_admin":false},"created_at":"2015-12-11T07:56:25Z","updated_at":"2015-12-11T07:56:25Z","body":"Yes, it's reproducible.\r\nIn order to make \"debug=broker,topic\" effective, must I explicitly set log_cb? I don't use log_cb right now. And the log of application behavior seems no difference with that not using \"debug=broker,topic\"."}}