{"action":"created","issue":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/1345","repository_url":"https://api.github.com/repos/edenhill/librdkafka","labels_url":"https://api.github.com/repos/edenhill/librdkafka/issues/1345/labels{/name}","comments_url":"https://api.github.com/repos/edenhill/librdkafka/issues/1345/comments","events_url":"https://api.github.com/repos/edenhill/librdkafka/issues/1345/events","html_url":"https://github.com/edenhill/librdkafka/issues/1345","id":246182288,"number":1345,"title":"Unnecessary TCP connection is kept between Producer and Kafka cluster","user":{"login":"kfdx87","id":30352818,"avatar_url":"https://avatars2.githubusercontent.com/u/30352818?v=4","gravatar_id":"","url":"https://api.github.com/users/kfdx87","html_url":"https://github.com/kfdx87","followers_url":"https://api.github.com/users/kfdx87/followers","following_url":"https://api.github.com/users/kfdx87/following{/other_user}","gists_url":"https://api.github.com/users/kfdx87/gists{/gist_id}","starred_url":"https://api.github.com/users/kfdx87/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kfdx87/subscriptions","organizations_url":"https://api.github.com/users/kfdx87/orgs","repos_url":"https://api.github.com/users/kfdx87/repos","events_url":"https://api.github.com/users/kfdx87/events{/privacy}","received_events_url":"https://api.github.com/users/kfdx87/received_events","type":"User","site_admin":false},"labels":[{"id":14337453,"url":"https://api.github.com/repos/edenhill/librdkafka/labels/question","name":"question","color":"cc317c","default":true}],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2017-07-27T22:01:49Z","updated_at":"2017-07-28T08:07:58Z","closed_at":null,"body":"Description\r\n===========\r\n**librdkafka** library maintains the redundant TCP connection with one of the Kafka brokers (with the broker which was configured as a bootstrap server).\r\n\r\n\r\nHow to reproduce\r\n================\r\n1. Use C++ binding of **librdkafka** library.\r\n2. Prepare Apache Kafka cluster with 3 brokers: X, Y and Z.\r\n3. Create **Conf** object (of global type), set the broker X as a bootstrap server via **metadata.broker.list** config. property.\r\n4. Create **Producer** object using that **Conf** object.\r\n5. Create some **Topic** objects just in case (not sure that it's necessary, but it is a very usual step).\r\n6. Monitor network connections between the test host and XYZ-cluster. There are 4 TCP connections between the test host and XYZ-cluster: 2 with X broker, 1 with Y broker and 1 with Z broker.\r\n7. NOTE: **librdkafka** automatically recovers these 4 TCP connections, i.e. if any of them is killed via appropriate test tools, then it will be re-established.\r\n\r\nIs it really needed to keep 2 TCP connections with broker X?\r\n\r\n\r\nChecklist\r\n=========\r\nPlease provide the following information:\r\n\r\n - [X] librdkafka version (release number or git tag): v0.9.5\r\n - [X] Apache Kafka version: 0.10.1\r\n - [ ] librdkafka client configuration:\r\n - [X] Operating system: Windows 8.1\r\n - [X] Using the legacy Consumer: no\r\n - [X] Using the high-level KafkaConsumer: no\r\n - [ ] Provide logs (with `debug=..` as necessary) from librdkafka: no, it's reproduced in 100% cases.\r\n - [ ] Provide broker log excerpts: no\r\n - [X] Critical issue: not critical\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/comments/318589530","html_url":"https://github.com/edenhill/librdkafka/issues/1345#issuecomment-318589530","issue_url":"https://api.github.com/repos/edenhill/librdkafka/issues/1345","id":318589530,"user":{"login":"kfdx87","id":30352818,"avatar_url":"https://avatars2.githubusercontent.com/u/30352818?v=4","gravatar_id":"","url":"https://api.github.com/users/kfdx87","html_url":"https://github.com/kfdx87","followers_url":"https://api.github.com/users/kfdx87/followers","following_url":"https://api.github.com/users/kfdx87/following{/other_user}","gists_url":"https://api.github.com/users/kfdx87/gists{/gist_id}","starred_url":"https://api.github.com/users/kfdx87/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kfdx87/subscriptions","organizations_url":"https://api.github.com/users/kfdx87/orgs","repos_url":"https://api.github.com/users/kfdx87/repos","events_url":"https://api.github.com/users/kfdx87/events{/privacy}","received_events_url":"https://api.github.com/users/kfdx87/received_events","type":"User","site_admin":false},"created_at":"2017-07-28T08:07:58Z","updated_at":"2017-07-28T08:07:58Z","body":"Wow, perfect, it helps! @edenhill, thank you!"}}
{"actor":{"display_login":"kfdx87"}}