diff --git a/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs b/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs index d4e819496..b808d5af2 100644 --- a/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs +++ b/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs @@ -16,11 +16,16 @@ public Task Handle(IMessageContext context, PauseConsumerByName message) { var consumer = _consumerAccessor[message.ConsumerName]; + if (consumer is null) + { + return Task.CompletedTask; + } + var assignment = consumer.FilterAssigment(message.Topics); if (assignment.Any()) { - consumer?.Pause(assignment); + consumer.Pause(assignment); } return Task.CompletedTask;