From 095d42e006e16dc2faaea2f2db0ce7b7c052156d Mon Sep 17 00:00:00 2001
From: Savorboard <yangxiaodong1214@126.com>
Date: Tue, 25 Jul 2017 00:37:31 +0800
Subject: [PATCH] add queue.buffering config.

---
 src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs b/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs
index 34cf92d..f676b45 100644
--- a/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs
+++ b/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs
@@ -44,6 +44,8 @@ namespace DotNetCore.CAP
             {
                 MainConfig.Add("bootstrap.servers", Servers);
             }
+            MainConfig["queue.buffering.max.ms"] = "10";
+            MainConfig["socket.blocking.max.ms"] = "10";
             MainConfig["enable.auto.commit"] = "false";
             return MainConfig.AsEnumerable();
         }