diff --git a/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs b/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs
index ed235c8..29680e4 100644
--- a/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs
+++ b/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs
@@ -106,7 +106,7 @@ namespace DotNetCore.CAP.Kafka
                     var customHeaders = _kafkaOptions.CustomHeaders(consumerResult);
                     foreach (var customHeader in customHeaders)
                     {
-                        headers.Add(customHeader.Key, customHeader.Value);
+                        headers[customHeader.Key] = customHeader.Value;
                     }
                 }
 
@@ -177,6 +177,6 @@ namespace DotNetCore.CAP.Kafka
                 Reason = $"An error occurred during connect kafka --> {e.Reason}"
             };
             OnLog?.Invoke(null, logArgs);
-        } 
+        }
     }
 }
\ No newline at end of file