quieter logger

This commit is contained in:
Adam R. Grey 2021-10-24 10:04:55 -04:00
parent 1f9d1fac23
commit 4597df6d96
2 changed files with 11 additions and 1 deletions

View File

@ -27,7 +27,7 @@ namespace franz
= new Dictionary<string, KafkaConsumer<string, string>>(); = new Dictionary<string, KafkaConsumer<string, string>>();
private Dictionary<string, int> topicSubscribers { get; set; } = new Dictionary<string, int>(); private Dictionary<string, int> topicSubscribers { get; set; } = new Dictionary<string, int>();
private Kafka.Public.Configuration clusterClientConfig = null; private Kafka.Public.Configuration clusterClientConfig = null;
private static ConsoleLogger consoleLogger = new ConsoleLogger(); private static quieterLogger consoleLogger = new quieterLogger();
private Telefranz(string name, string bootstrap_servers, private Telefranz(string name, string bootstrap_servers,
List<string> commands = null, List<string> checks = null, List<string> commands = null, List<string> checks = null,
List<string> errors = null, List<string> warnings = null) List<string> errors = null, List<string> warnings = null)

10
franz/quieterLogger.cs Normal file
View File

@ -0,0 +1,10 @@
using Kafka.Public.Loggers;
namespace franz
{
internal class quieterLogger : ConsoleLogger
{
new public void LogInformation(string message) {}
}
}