1

src/YSAI.DAQ/YSAI.Kafka/KafkaOperate.cs

@@ -350,13 +350,9 @@ namespace YSAI.Kafka
                     producerConfig = new ProducerConfig()
                     {
                         ClientId = Guid.NewGuid().ToString(),
-                        BootstrapServers = basics.BootstrapServers
-                        //,
-                        //SecurityProtocol = basics.SecurityProtocol,
-                        //SaslMechanism = basics.SaslMechanism,
-                        //SaslKerberosServiceName = basics.SaslKerberosServiceName,
-                        //SaslKerberosKeytab = basics.SaslKerberosKeytab,
-                        //SaslKerberosPrincipal = basics.SaslKerberosPrincipal
+                        BootstrapServers = basics.BootstrapServers,
+                        EnableIdempotence=true,
+                        SecurityProtocol = basics.SecurityProtocol
                     };
                 }
 
@@ -367,7 +363,8 @@ namespace YSAI.Kafka
                     {
                         BootstrapServers = basics.BootstrapServers,
                         GroupId = Guid.NewGuid().ToString(),
-                        AutoOffsetReset = basics.AutoOffsetReset
+                        AutoOffsetReset = basics.AutoOffsetReset,
+                        SecurityProtocol = basics.SecurityProtocol
                     };
                 }
 

src/YSAI.DAQ/YSAI.Test.Console/Program.cs

@@ -16,30 +16,37 @@ using YSAI.S7.client;
 using YSAI.Unility;
 
 
-
-MqttClientOperate mqttClientOperate = MqttClientOperate.Instance(new MqttClientData.Basics()
+MqttWebSocketServiceOperate mqttWebSocketServiceOperate = MqttWebSocketServiceOperate.Instance(new MqttWebSocketServiceData.Basics() 
 {
-    ServerIPAddress = "127.0.0.1",
-    ServerPort=8881,
-    ServerLoginID="ysai",
-    ServerLoginPassword="ysai",
-    SN = "ysai"
+    HttpPort=11886,
+    Port=1188,
+    
 });
-OperateResult operateResult = mqttClientOperate.On();
-if (!operateResult.State)
-{
-    LogHelper.Warning(operateResult.ToJson());
-}
 
-while (true)
-{
-    operateResult = mqttClientOperate.Produce("666", "123");
-    if (!operateResult.State)
-    {
-        LogHelper.Warning(operateResult.ToJson());
-    }
-    Thread.Sleep(1000);
-}
+
+//MqttClientOperate mqttClientOperate = MqttClientOperate.Instance(new MqttClientData.Basics()
+//{
+//    ServerIPAddress = "192.168.2.200",
+//    ServerPort= 5101,
+//    ServerLoginID="ys",
+//    ServerLoginPassword="ys123456",
+//    SN = "ysai"
+//});
+//OperateResult operateResult = mqttClientOperate.On();
+//if (!operateResult.State)
+//{
+//    LogHelper.Warning(operateResult.ToJson());
+//}
+
+//while (true)
+//{
+//    operateResult = mqttClientOperate.Produce("666", "123");
+//    if (!operateResult.State)
+//    {
+//        LogHelper.Warning(operateResult.ToJson());
+//    }
+//    Thread.Sleep(1000);
+//}
 ////对象实例
 //S7ClientOperate s7ClientOperate = S7ClientOperate.Instance(new S7ClientData.Basics()
 //{