diff --git a/src/SlimMessageBus.Host.Kafka/Consumer/KafkaGroupConsumer.cs b/src/SlimMessageBus.Host.Kafka/Consumer/KafkaGroupConsumer.cs index 19f6dba9..8d8cf2f9 100644 --- a/src/SlimMessageBus.Host.Kafka/Consumer/KafkaGroupConsumer.cs +++ b/src/SlimMessageBus.Host.Kafka/Consumer/KafkaGroupConsumer.cs @@ -170,7 +170,7 @@ protected override async Task OnStop() { _consumerTask = null; - _consumerCts.DisposeSilently(); + _consumerCts.Dispose(); _consumerCts = null; } }