{"action":"created","issue":{"url":"https://api.github.com/repos/SOHU-Co/kafka-node/issues/289","repository_url":"https://api.github.com/repos/SOHU-Co/kafka-node","labels_url":"https://api.github.com/repos/SOHU-Co/kafka-node/issues/289/labels{/name}","comments_url":"https://api.github.com/repos/SOHU-Co/kafka-node/issues/289/comments","events_url":"https://api.github.com/repos/SOHU-Co/kafka-node/issues/289/events","html_url":"https://github.com/SOHU-Co/kafka-node/issues/289","id":122776129,"number":289,"title":"Producer send request timeout","user":{"login":"hyperlink","id":133309,"avatar_url":"https://avatars.githubusercontent.com/u/133309?v=3","gravatar_id":"","url":"https://api.github.com/users/hyperlink","html_url":"https://github.com/hyperlink","followers_url":"https://api.github.com/users/hyperlink/followers","following_url":"https://api.github.com/users/hyperlink/following{/other_user}","gists_url":"https://api.github.com/users/hyperlink/gists{/gist_id}","starred_url":"https://api.github.com/users/hyperlink/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/hyperlink/subscriptions","organizations_url":"https://api.github.com/users/hyperlink/orgs","repos_url":"https://api.github.com/users/hyperlink/repos","events_url":"https://api.github.com/users/hyperlink/events{/privacy}","received_events_url":"https://api.github.com/users/hyperlink/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":4,"created_at":"2015-12-17T16:55:41Z","updated_at":"2016-03-31T20:40:12Z","closed_at":null,"body":"What do you think about adding a timeout capability to the `producer.send`? This is different than the `ackTimeoutMs` since that is dealing with a processing timeout on the broker side.\r\n\r\nThe use case is if there is network issue to the kafka server and the message is never sent through the socket (or ack is not received) the callback will never get called. Eventually the client will raise errors but that is not helpful because the caller of `send` is oblivious to the status of that request.\r\n\r\nA similar feature is available in the Kafka's console producer as `--request-timeout-ms`. If there's network issue and the messages are not sent with in the timeout an error is thrown. In node-kafka's case after the timeout has passed the callback should be invoked with a timeout error.\r\n\r\nI will look into coding this up in my branch. Thanks!"},"comment":{"url":"https://api.github.com/repos/SOHU-Co/kafka-node/issues/comments/204116884","html_url":"https://github.com/SOHU-Co/kafka-node/issues/289#issuecomment-204116884","issue_url":"https://api.github.com/repos/SOHU-Co/kafka-node/issues/289","id":204116884,"user":{"login":"eastlondoner","id":8148776,"avatar_url":"https://avatars.githubusercontent.com/u/8148776?v=3","gravatar_id":"","url":"https://api.github.com/users/eastlondoner","html_url":"https://github.com/eastlondoner","followers_url":"https://api.github.com/users/eastlondoner/followers","following_url":"https://api.github.com/users/eastlondoner/following{/other_user}","gists_url":"https://api.github.com/users/eastlondoner/gists{/gist_id}","starred_url":"https://api.github.com/users/eastlondoner/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/eastlondoner/subscriptions","organizations_url":"https://api.github.com/users/eastlondoner/orgs","repos_url":"https://api.github.com/users/eastlondoner/repos","events_url":"https://api.github.com/users/eastlondoner/events{/privacy}","received_events_url":"https://api.github.com/users/eastlondoner/received_events","type":"User","site_admin":false},"created_at":"2016-03-31T20:40:12Z","updated_at":"2016-03-31T20:40:12Z","body":"Ahhhh running into this problem as well. any ideas?"}}