From 3d5ee80e1067cf55dc3638d1298f301eb6f3fa7a Mon Sep 17 00:00:00 2001 From: gdvalishvili1 Date: Thu, 13 Mar 2025 13:28:22 +0400 Subject: [PATCH 1/2] feat: Change warning log to info when topic already exists in CreateTopicIfNotExists --- src/KafkaFlow/Clusters/ClusterManager.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/KafkaFlow/Clusters/ClusterManager.cs b/src/KafkaFlow/Clusters/ClusterManager.cs index 73ba26ba2..36c434c33 100644 --- a/src/KafkaFlow/Clusters/ClusterManager.cs +++ b/src/KafkaFlow/Clusters/ClusterManager.cs @@ -135,8 +135,8 @@ public async Task CreateIfNotExistsAsync(IEnumerable configu { if (exceptionResult.Error.Code == ErrorCode.TopicAlreadyExists) { - _logHandler.Warning( - "An error occurred creating topic {Topic}: {Reason}", + _logHandler.Info( + "Topic {Topic} already exists. Skipping creation.", new { exceptionResult.Topic, @@ -169,4 +169,4 @@ public void Dispose() _lazyAdminClient.Value.Dispose(); } } -} +} \ No newline at end of file From d315ade0453dd3baa24d9584c12ac7714c29b576 Mon Sep 17 00:00:00 2001 From: gdvalishvili1 Date: Thu, 13 Mar 2025 13:34:13 +0400 Subject: [PATCH 2/2] chore: Normalize line endings --- src/KafkaFlow/Clusters/ClusterManager.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/KafkaFlow/Clusters/ClusterManager.cs b/src/KafkaFlow/Clusters/ClusterManager.cs index 36c434c33..4627bfbe1 100644 --- a/src/KafkaFlow/Clusters/ClusterManager.cs +++ b/src/KafkaFlow/Clusters/ClusterManager.cs @@ -169,4 +169,4 @@ public void Dispose() _lazyAdminClient.Value.Dispose(); } } -} \ No newline at end of file +}