title: Kafka Producer Request Timeout setting
body: <p>I would like to set request time-out so added request.timeout.ms parameter.
  Bu when I have broken instinctively the broker connection there is not any timeout error occur?</p>
  
  <p>What I am missing in this configuration? Do I need to modify server setting as well?</p>
  
  <pre><code> public void init() {
            LOGGER.info("initializing  KafkaProducer: Topic Name: {}", topic);
            System.out.println("initializing  KafkaProducer: Topic Name: {}");
            Properties properties = new Properties();
            properties.put("bootstrap.servers", brokerList);
            properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
            properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
            properties.put("acks", "1");
            properties.put("retries", "3");
            properties.put("linger.ms", 5);
            properties.put("block.on.buffer.full", false);
            properties.put("request.timeout.ms", "1000");
            //properties.put("metadata.fetch.timeout.ms", 1000);
  
  
  
            producer = new KafkaProducer&lt;&gt;(properties);
         }
  
  
          public void produce(String txnLogStr) {
            ProducerRecord&lt;String, String&gt; record = new ProducerRecord&lt;String, String&gt;(topic, txnLogStr);
            producer.send(record, new ProducerCallback());   
  
         }
  
         private class ProducerCallback implements Callback {
            @Override
            public void onCompletion(RecordMetadata recordMetadata, Exception e) {
                System.out.println("onCompletion recordMetadata:"+recordMetadata.offset()+", e:"+e);
               if (e != null &amp;&amp; recordMetadata != null) {
                  LOGGER.error("Kafka Queue problem. Topic: {}", topic, e);
                  e.printStackTrace();
               }else {
                   System.out.println("No error");
               }
            }
         }
  </code></pre>
  
  <p><strong>Kafka version</strong> : kafka_2.11-0.10.2.0</p>
  
  <p><strong>pom.xml</strong></p>
  
  <pre><code> &lt;dependencies&gt;
      &lt;dependency&gt;
              &lt;groupId&gt;org.apache.kafka&lt;/groupId&gt;
              &lt;artifactId&gt;kafka_2.11&lt;/artifactId&gt;
              &lt;version&gt;0.10.2.0&lt;/version&gt;         
  
          &lt;/dependency&gt;
          &lt;dependency&gt;
              &lt;groupId&gt;org.apache.kafka&lt;/groupId&gt;
              &lt;artifactId&gt;kafka-clients&lt;/artifactId&gt;
              &lt;version&gt;0.10.2.0&lt;/version&gt; 
  
          &lt;/dependency&gt;
  
  
    &lt;/dependencies&gt;
  </code></pre>