Преглед на файлове
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 <andrewj@avi.com>
master
Andrew Jaffie
преди 4 години
committed by
GitHub
родител
ревизия
14e67a6e37
No known key found for this signature in database
GPG ключ ID: 4AEE18F83AFDEB23
променени са
1 файла, в които са
добавени 0 реда и са
изтрити 2 реда
-
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); |
|
|
|