Browse Source

add default timeout configuration for kafka client.

undefined
Savorboard 6 years ago
parent
commit
0058f42127
1 changed files with 2 additions and 0 deletions
  1. +2
    -0
      src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs

+ 2
- 0
src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs View File

@@ -57,6 +57,8 @@ namespace DotNetCore.CAP
MainConfig["socket.blocking.max.ms"] = "10"; MainConfig["socket.blocking.max.ms"] = "10";
MainConfig["enable.auto.commit"] = "false"; MainConfig["enable.auto.commit"] = "false";
MainConfig["log.connection.close"] = "false"; MainConfig["log.connection.close"] = "false";
MainConfig["request.timeout.ms"] = "3000";
MainConfig["message.timeout.ms"] = "5000";


_kafkaConfig = MainConfig.AsEnumerable(); _kafkaConfig = MainConfig.AsEnumerable();
} }


Loading…
Cancel
Save