{"action":"created","issue":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/405","labels_url":"https://api.github.com/repos/edenhill/librdkafka/issues/405/labels{/name}","comments_url":"https://api.github.com/repos/edenhill/librdkafka/issues/405/comments","events_url":"https://api.github.com/repos/edenhill/librdkafka/issues/405/events","html_url":"https://github.com/edenhill/librdkafka/issues/405","id":114734027,"number":405,"title":"Producer: throw out error message \"Local: Message timed out\"","user":{"login":"wbtwins","id":11252843,"avatar_url":"https://avatars.githubusercontent.com/u/11252843?v=3","gravatar_id":"","url":"https://api.github.com/users/wbtwins","html_url":"https://github.com/wbtwins","followers_url":"https://api.github.com/users/wbtwins/followers","following_url":"https://api.github.com/users/wbtwins/following{/other_user}","gists_url":"https://api.github.com/users/wbtwins/gists{/gist_id}","starred_url":"https://api.github.com/users/wbtwins/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/wbtwins/subscriptions","organizations_url":"https://api.github.com/users/wbtwins/orgs","repos_url":"https://api.github.com/users/wbtwins/repos","events_url":"https://api.github.com/users/wbtwins/events{/privacy}","received_events_url":"https://api.github.com/users/wbtwins/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2015-11-03T03:09:16Z","updated_at":"2015-11-03T03:22:04Z","closed_at":null,"body":"hi,edenhill\r\n   We downloaded librdkafka-master and deployed it on the centos.it would throw out  \"Local: Message timed out\" when we run example/example_rdkafka in producer Mode.Following is our command line:\r\n./rdkafka_example -P -t test -p 0  -b 192.168.84.183 -d all\r\n\r\nIt would throw out message \"local message timeout\" after the inputed stuff  is time out for delivery.\r\n\r\nwe traced the code,and found that the message had been enquened,we would print the message in \r\nrktp->rktp_msgq->rhq_>first->rkm_payload\r\n\r\nwe also tried rdkafka_performance and other binary in test,it had the same result ,no matter we took jafka-1.4.0 or kafka_2.9.1-0.8.2.2 as our server side.\r\n\r\nThe config of rdkafka we used is default.\r\n \r\nIs there any other condition we should set in our environment?\r\n\r\n\r\n\r\n[root@localhost examples]# ./rdkafka_example -P -t test -p 0  -b 192.168.84.183 -d all\r\n1446518837.618 RDKAFKA-7-BROKER: rdkafka#producer-0: 192.168.84.183:9092/1: Added new broker with NodeId 1\r\n1446518837.618 RDKAFKA-7-TOPIC: rdkafka#producer-0: New local topic: test\r\n1446518837.618 RDKAFKA-7-BRKMAIN: rdkafka#producer-0: 192.168.84.183:9092/1: Enter main broker thread\r\n1446518837.618 RDKAFKA-7-CONNECT: rdkafka#producer-0: 192.168.84.183:9092/1: broker in state INIT connecting\r\n% Type stuff and hit enter to send\r\n1446518837.621 RDKAFKA-7-CONNECTED: rdkafka#producer-0: 192.168.84.183:9092/1: connected to <unsupported:inet>\r\n1446518837.621 RDKAFKA-7-STATE: rdkafka#producer-0: 192.168.84.183:9092/1: Broker changed state INIT -> UP\r\n1446518837.621 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Request metadata for all topics: connected\r\n1446518837.621 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Requesting metadata for all topics\r\n1446518837.621 RDKAFKA-7-SEND: rdkafka#producer-0: 192.168.84.183:9092/1: Sent MetadataRequest (25 bytes, CorrId 1)\r\n1446518838.618 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Request metadata for test: leader query\r\n1446518838.618 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Request metadata: scheduled: not in broker thread\r\n1446518838.623 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Request metadata for test: leader query\r\n1446518838.623 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Requesting metadata for known topics\r\n1446518838.623 RDKAFKA-7-SEND: rdkafka#producer-0: 192.168.84.183:9092/1: Sent MetadataRequest (31 bytes, CorrId 2)\r\nksdfjksdjklfjklsdjfkljsdkljfklsdjkfljsdkjfksdjfkljsdkfj\r\n% Sent 55 bytes to topic test partition 0\r\nsdfkjsdkjfkldsjklfjkdsljfkldsjklfjksdl\r\n% Sent 38 bytes to topic test partition 0\r\n1446518898.690 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: ===== Received metadata from 192.168.84.183:9092/1 =====\r\n1446518898.690 RDKAFKA-4-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Metadata request failed: Local: Message timed out\r\n1446518898.690 RDKAFKA-7-REQTMOUT: rdkafka#producer-0: 192.168.84.183:9092/1: Timed out 1 requests\r\n1446518899.691 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: ===== Received metadata from 192.168.84.183:9092/1 =====\r\n1446518899.691 RDKAFKA-4-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Metadata request failed: Local: Message timed out\r\n1446518899.691 RDKAFKA-7-REQTMOUT: rdkafka#producer-0: 192.168.84.183:9092/1: Timed out 1 requests\r\n1446518900.633 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Request metadata for test: leader query\r\n1446518900.633 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Request metadata: scheduled: not in broker thread\r\n1446518900.691 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Request metadata for test: leader query\r\n1446518900.691 RDKAFKA-7-METADATA: rdkafka#producer-0: 192.168.84.183:9092/1: Requesting metadata for known topics\r\n1446518900.692 RDKAFKA-7-SEND: rdkafka#producer-0: 192.168.84.183:9092/1: Sent MetadataRequest (31 bytes, CorrId 3)\r\n\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/edenhill/librdkafka/issues/comments/153230827","html_url":"https://github.com/edenhill/librdkafka/issues/405#issuecomment-153230827","issue_url":"https://api.github.com/repos/edenhill/librdkafka/issues/405","id":153230827,"user":{"login":"wbtwins","id":11252843,"avatar_url":"https://avatars.githubusercontent.com/u/11252843?v=3","gravatar_id":"","url":"https://api.github.com/users/wbtwins","html_url":"https://github.com/wbtwins","followers_url":"https://api.github.com/users/wbtwins/followers","following_url":"https://api.github.com/users/wbtwins/following{/other_user}","gists_url":"https://api.github.com/users/wbtwins/gists{/gist_id}","starred_url":"https://api.github.com/users/wbtwins/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/wbtwins/subscriptions","organizations_url":"https://api.github.com/users/wbtwins/orgs","repos_url":"https://api.github.com/users/wbtwins/repos","events_url":"https://api.github.com/users/wbtwins/events{/privacy}","received_events_url":"https://api.github.com/users/wbtwins/received_events","type":"User","site_admin":false},"created_at":"2015-11-03T03:22:04Z","updated_at":"2015-11-03T03:22:04Z","body":"edenhill,\r\n   would the rdkafka client  support Jafka server?or it can only communicate with Kafka server?\r\n   \r\n\r\nThanks in advance！\r\n"}}