From 14e67a6e37f820f8e4e3113fd1f30371e5c9d84c Mon Sep 17 00:00:00 2001 From: Andrew Jaffie Date: Sat, 14 Mar 2020 08:15:27 -0400 Subject: [PATCH] Removes line that added the kafka key to headers an extra time. (#524) This caused any messages published by CAP with a kafka key set to not be consumable by CAP. Co-authored-by: Andrew Jaffie --- src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs b/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs index b5df965..e4de064 100644 --- a/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs +++ b/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs @@ -62,8 +62,6 @@ namespace DotNetCore.CAP.Kafka } headers.Add(Messages.Headers.Group, _groupId); - headers.Add(KafkaHeaders.KafkaKey, consumerResult.Key); - if (_kafkaOptions.CustomHeaders != null) { var customHeaders = _kafkaOptions.CustomHeaders(consumerResult);