From b67f6f231988d8c9863eef3240c29d6b8a9e2455 Mon Sep 17 00:00:00 2001 From: imperugo Date: Tue, 20 Aug 2024 10:51:32 +0200 Subject: [PATCH 1/2] Fixed possible null exception --- src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs b/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs index d4e819496..7756c5d9e 100644 --- a/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs +++ b/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs @@ -16,11 +16,14 @@ 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; From 84c9fa85ae4a899023ba5854a342fb665b871802 Mon Sep 17 00:00:00 2001 From: imperugo Date: Tue, 20 Aug 2024 11:20:48 +0200 Subject: [PATCH 2/2] Fixed Codacy Static Code Analysis --- src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs b/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs index 7756c5d9e..b808d5af2 100644 --- a/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs +++ b/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs @@ -16,8 +16,10 @@ public Task Handle(IMessageContext context, PauseConsumerByName message) { var consumer = _consumerAccessor[message.ConsumerName]; - if(consumer is null) + if (consumer is null) + { return Task.CompletedTask; + } var assignment = consumer.FilterAssigment(message.Topics);