fixed kafka received message sava failed caused the mssage loss bug. #78

e414aef4 · Savorboard · 8c640206 · e414aef4
Commit e414aef4 authored Jan 20, 2018 by Savorboard
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

KafkaConsumerClient.cs src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs +1 -1

No files found.
--- a/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs
+++ b/src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs
@@ -54,7 +54,7 @@ namespace DotNetCore.CAP.Kafka

        public void Reject()
        {
-            // Ignore, Kafka will not commit offset when not commit.
+            _consumerClient.Assign(_consumerClient.Assignment);
        }

        public void Dispose()