Browse Source

disabled print connection closed log. see: https://github.com/edenhill/librdkafka/issues/516

master
Savorboard 7 years ago
parent
commit
96a127a8ff
1 changed files with 2 additions and 1 deletions
  1. +2
    -1
      src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs

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

@@ -51,7 +51,8 @@ namespace DotNetCore.CAP
MainConfig["queue.buffering.max.ms"] = "10"; MainConfig["queue.buffering.max.ms"] = "10";
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";
_kafkaConfig = MainConfig.AsEnumerable(); _kafkaConfig = MainConfig.AsEnumerable();
} }
return _kafkaConfig; return _kafkaConfig;


Loading…
Cancel
Save