Fix issue with unrecognized commands (#483) (#489)

masesgroup · Jun 11, 2024 · dbd4616 · dbd4616
1 parent 3be1029
commit dbd4616
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/src/net/KNet/KNetCore.cs b/src/net/KNet/KNetCore.cs
@@ -17,17 +17,10 @@
 */
 
 using MASES.CLIParser;
-using Org.Apache.Kafka.Clients.Consumer;
-using Org.Apache.Kafka.Clients.Producer;
-using Org.Apache.Kafka.Common;
-using Org.Apache.Kafka.Common.Errors;
-using Org.Apache.Kafka.Connect.Errors;
-using Org.Apache.Kafka.Streams.Errors;
 using System;
 using System.Collections.Generic;
 using System.IO;
 using MASES.JNet;
-using Org.Apache.Kafka.Common.Config;
 
 namespace MASES.KNet
 {
@@ -149,7 +142,7 @@ protected override string[] ProcessCommandLine()
         /// <exception cref="ArgumentException">If <paramref name="className"/> does not have a corresponding implemented <see cref="Type"/></exception>
         protected virtual void PrepareMainClassToRun(string className)
         {
-            if (!string.IsNullOrEmpty(className)) return;
+            if (string.IsNullOrEmpty(className)) return;
             Type type = null;
             foreach (var item in typeof(KNetCore<>).Assembly.ExportedTypes)
             {