Comment ：实例producer中增加请求超时和元数据更新周期配置

nicklyc · Jul 2, 2019 · 62515cf · 62515cf
1 parent d02d022
commit 62515cf
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/learn2/src/main/java/org/example/learn2/producer/ProducerConf.java b/learn2/src/main/java/org/example/learn2/producer/ProducerConf.java
@@ -20,6 +20,10 @@ public static Properties initProperties() {
         Properties properties = new Properties();
         properties.put(org.apache.kafka.clients.producer.ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, url);
         properties.put(org.apache.kafka.clients.producer.ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
+        //请求最大的超时时间
+        properties.put("request.timeout.ms", 50);
+        //元数据更新周期
+        properties.put("metadata.max.age.ms", 5000);
 
         //自定义拦截器
         properties.put(ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, Interceptor.class.getName());