upgrade Confluent.Kafka to 1.4.3

Author: yang-xiaodong

src/DotNetCore.CAP.Kafka/DotNetCore.CAP.Kafka.csproj

@@ -13,7 +13,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Confluent.Kafka" Version="1.3.0" />
+    <PackageReference Include="Confluent.Kafka" Version="1.4.3" />
   </ItemGroup>
 
   <ItemGroup>

src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs

@@ -52,10 +52,10 @@ public void Listening(TimeSpan timeout, CancellationToken cancellationToken)
             {
                 var consumerResult = _consumerClient.Consume(cancellationToken);
 
-                if (consumerResult.IsPartitionEOF || consumerResult.Value == null) continue;
+                if (consumerResult.IsPartitionEOF || consumerResult.Message.Value == null) continue;
 
-                var headers = new Dictionary<string, string>(consumerResult.Headers.Count);
-                foreach (var header in consumerResult.Headers)
+                var headers = new Dictionary<string, string>(consumerResult.Message.Headers.Count);
+                foreach (var header in consumerResult.Message.Headers)
                 {
                     var val = header.GetValueBytes();
                     headers.Add(header.Key, val != null ? Encoding.UTF8.GetString(val) : null);
@@ -71,7 +71,7 @@ public void Listening(TimeSpan timeout, CancellationToken cancellationToken)
                     }
                 }
 
-                var message = new TransportMessage(headers, consumerResult.Value);
+                var message = new TransportMessage(headers, consumerResult.Message.Value);
 
                 OnMessageReceived?.Invoke(consumerResult, message);
             }