diff --git a/franz.tests/UnitTest1.cs b/franz.tests/UnitTest1.cs new file mode 100644 index 0000000..9186446 --- /dev/null +++ b/franz.tests/UnitTest1.cs @@ -0,0 +1,15 @@ +using franz; +using System; +using Xunit; + +namespace franz.tests +{ + public class UnitTest1 + { + [Fact] + public void Test1() + { + Telefranz.Configure("xunit", "focalor:9092"); + } + } +} diff --git a/franz.tests/franz.tests.csproj b/franz.tests/franz.tests.csproj new file mode 100644 index 0000000..c58ee5c --- /dev/null +++ b/franz.tests/franz.tests.csproj @@ -0,0 +1,23 @@ + + + + net5.0 + + false + + + + + + + + runtime; build; native; contentfiles; analyzers; buildtransitive + all + + + runtime; build; native; contentfiles; analyzers; buildtransitive + all + + + + diff --git a/franz/quieterLogger.cs b/franz/quieterLogger.cs index c3a6073..db27046 100644 --- a/franz/quieterLogger.cs +++ b/franz/quieterLogger.cs @@ -1,10 +1,26 @@ - +using System; +using Kafka.Public; using Kafka.Public.Loggers; namespace franz { - internal class quieterLogger : ConsoleLogger + internal class quieterLogger : ILogger { - new public void LogInformation(string message) {} + public void LogDebug(string message) + { + Console.WriteLine($"[{DateTime.Now}] [DEBUG]: {message}"); + } + public void LogError(string message) + { + Console.Error.WriteLine($"[{DateTime.Now}] [ERROR]: {message}"); + } + public void LogInformation(string message) + { + //Console.WriteLine($"[INFO]: {message}"); + } + public void LogWarning(string message) + { + Console.WriteLine($"[{DateTime.Now}] [Warning]: {message}"); + } } } \ No newline at end of file