{"action":"created","issue":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/373","labels_url":"https://api.github.com/repos/edenhill/librdkafka/issues/373/labels{/name}","comments_url":"https://api.github.com/repos/edenhill/librdkafka/issues/373/comments","events_url":"https://api.github.com/repos/edenhill/librdkafka/issues/373/events","html_url":"https://github.com/edenhill/librdkafka/issues/373","id":107158835,"number":373,"title":"rdkafka stopping connection retries on RdKafka::ERR__ALL_BROKERS_DOWN","user":{"login":"DEvil0000","id":3344302,"avatar_url":"https://avatars.githubusercontent.com/u/3344302?v=3","gravatar_id":"","url":"https://api.github.com/users/DEvil0000","html_url":"https://github.com/DEvil0000","followers_url":"https://api.github.com/users/DEvil0000/followers","following_url":"https://api.github.com/users/DEvil0000/following{/other_user}","gists_url":"https://api.github.com/users/DEvil0000/gists{/gist_id}","starred_url":"https://api.github.com/users/DEvil0000/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/DEvil0000/subscriptions","organizations_url":"https://api.github.com/users/DEvil0000/orgs","repos_url":"https://api.github.com/users/DEvil0000/repos","events_url":"https://api.github.com/users/DEvil0000/events{/privacy}","received_events_url":"https://api.github.com/users/DEvil0000/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-09-18T08:48:58Z","updated_at":"2015-10-12T14:59:46Z","closed_at":null,"body":"rdkafka is trying to connect to all brokers in the list, if they all fail I get a event_cb (ERR__ALL_BROKERS_DOWN) but no more connection attempts are done..\r\nI would expect rdkafka to report it but still try to connect to the brokers.\r\nIn case you do not think this should be the default behaviour I would suggest a config value for retry after all brokers down..."},"comment":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/comments/147424652","html_url":"https://github.com/edenhill/librdkafka/issues/373#issuecomment-147424652","issue_url":"https://api.github.com/repos/edenhill/librdkafka/issues/373","id":147424652,"user":{"login":"DEvil0000","id":3344302,"avatar_url":"https://avatars.githubusercontent.com/u/3344302?v=3","gravatar_id":"","url":"https://api.github.com/users/DEvil0000","html_url":"https://github.com/DEvil0000","followers_url":"https://api.github.com/users/DEvil0000/followers","following_url":"https://api.github.com/users/DEvil0000/following{/other_user}","gists_url":"https://api.github.com/users/DEvil0000/gists{/gist_id}","starred_url":"https://api.github.com/users/DEvil0000/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/DEvil0000/subscriptions","organizations_url":"https://api.github.com/users/DEvil0000/orgs","repos_url":"https://api.github.com/users/DEvil0000/repos","events_url":"https://api.github.com/users/DEvil0000/events{/privacy}","received_events_url":"https://api.github.com/users/DEvil0000/received_events","type":"User","site_admin":false},"created_at":"2015-10-12T14:59:46Z","updated_at":"2015-10-12T14:59:46Z","body":"if a single broker is going down it reconnects to it like I expect. (reconnecting)\r\nbut after all brokers down message all rdkafka threads exit. (exiting-.-)\r\nexample log:\r\n>ERROR (Local: All broker connections are down): 4/4 brokers are down\r\nLOG-3-FAIL: test-zkkafka-857feb05-1b9c-4c04-9918-a6727dc263cb:9092/bootstrap: Failed to connect to broker at test-zkkafka-857feb05-1b9c-4c04-9918-a6727dc263cb:9092: Connection refused\r\nERROR (Local: Broker transport failure): test-zkkafka-857feb05-1b9c-4c04-9918-a6727dc263cb:9092/bootstrap: Failed to connect to broker at test-zkkafka-857feb05-1b9c-4c04-9918-a6727dc263cb:9092: Connection refused\r\n[Threads exiting]\r\n\r\ncode to produce logs:\r\n>switch (iraEvent.type())\r\n    {\r\n        case RdKafka::Event::EVENT_ERROR:\r\n            L_ERROR << \"ERROR (\" << RdKafka::err2str(iraEvent.err()) << \"): \" <<\r\n                iraEvent.str() << LEnd;\r\n            if (iraEvent.err() == RdKafka::ERR__ALL_BROKERS_DOWN) {\r\n                setConnected(false);\r\n            }\r\n            break;\r\n        case RdKafka::Event::EVENT_STATS:\r\n            L_INFO << \"\\\"STATS\\\": \" << iraEvent.str() << LEnd;\r\n            break;\r\n        case RdKafka::Event::EVENT_LOG:\r\n            L_DEBUG << \"LOG-\" << iraEvent.severity() << \"-\" <<\r\n                iraEvent.fac().c_str() << \": \" << iraEvent.str().c_str() << LEnd;\r\n            break;\r\n        default:\r\n            L_ERROR << \"EVENT \" << iraEvent.type() <<\r\n                \" (\" << RdKafka::err2str(iraEvent.err()) << \"): \" <<\r\n                iraEvent.str() << LEnd;\r\n            break;\r\n    }"}}