Add option which controls whether topic is created on startup or not (#202)

Author: boma96

src/ConductorSharp.Client/ConductorSharp.Client.csproj

@@ -6,7 +6,7 @@
 		<Authors>Codaxy</Authors>
 		<Company>Codaxy</Company>
 		<PackageId>ConductorSharp.Client</PackageId>
-		<Version>3.3.0</Version>
+		<Version>3.4.0</Version>
 		<Description>Client library for Netflix Conductor, with some additional quality of life features.</Description>
 		<RepositoryUrl>https://github.com/codaxy/conductor-sharp</RepositoryUrl>
 		<PackageTags>netflix;conductor</PackageTags>

src/ConductorSharp.Engine/ConductorSharp.Engine.csproj

@@ -6,7 +6,7 @@
     <Authors>Codaxy</Authors>
 	<Company>Codaxy</Company>
 	<PackageId>ConductorSharp.Engine</PackageId>
-	<Version>3.3.0</Version>
+	<Version>3.4.0</Version>
     <Description>Client library for Netflix Conductor, with some additional quality of life features.</Description>
 	<RepositoryUrl>https://github.com/codaxy/conductor-sharp</RepositoryUrl>
 	<PackageTags>netflix;conductor</PackageTags>

src/ConductorSharp.KafkaCancellationNotifier/ConductorSharp.KafkaCancellationNotifier.csproj

@@ -4,7 +4,7 @@
     <TargetFramework>net6.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
-    <Version>3.3.0</Version>
+    <Version>3.4.0</Version>
     <Authors>Codaxy</Authors>
     <Company>Codaxy</Company>
   </PropertyGroup>

src/ConductorSharp.KafkaCancellationNotifier/Extensions/ExecutionManagerBuilderExtensions.cs

@@ -11,7 +11,8 @@ public static IExecutionManagerBuilder AddKafkaCancellationNotifier(
             this IExecutionManagerBuilder builder,
             string kafkaBootstrapServers,
             string topicName,
-            string groupId
+            string groupId,
+            bool createTopicOnStartup = false
         )
         {
             ArgumentNullException.ThrowIfNull(kafkaBootstrapServers);
@@ -25,6 +26,7 @@ string groupId
                     opts.BootstrapServers = kafkaBootstrapServers;
                     opts.GroupId = groupId;
                     opts.TopicName = topicName;
+                    opts.CreateTopicOnStartup = createTopicOnStartup;
                 });
 
             builder.Builder.AddSingleton<ICancellationNotifier, Service.KafkaCancellationNotifier>();

src/ConductorSharp.KafkaCancellationNotifier/KafkaOptions.cs

@@ -1,12 +1,9 @@
-using System.ComponentModel.DataAnnotations;
-using Newtonsoft.Json;
+namespace ConductorSharp.KafkaCancellationNotifier;
 
-namespace ConductorSharp.KafkaCancellationNotifier
+internal class KafkaOptions
 {
-    internal class KafkaOptions
-    {
-        public string BootstrapServers { get; set; } = null!;
-        public string TopicName { get; set; } = null!;
-        public string GroupId { get; set; } = null!;
-    }
+    public string BootstrapServers { get; set; } = null!;
+    public string TopicName { get; set; } = null!;
+    public string GroupId { get; set; } = null!;
+    public bool CreateTopicOnStartup { get; set; }
 }

src/ConductorSharp.KafkaCancellationNotifier/Service/KafkaConsumerBackgroundService.cs

@@ -50,7 +50,8 @@ ICancellationNotifier notifier
 
         protected override async Task ExecuteAsync(CancellationToken stoppingToken)
         {
-            await CreateTopicIfDoesNotExists();
+            if (_kafkaOptions.Value.CreateTopicOnStartup)
+                await CreateTopicIfDoesNotExists();
 
             using var consumer = new ConsumerBuilder<string, TaskStatusModel>(
                 new ConsumerConfig

src/ConductorSharp.Patterns/ConductorSharp.Patterns.csproj

@@ -7,7 +7,7 @@
     <GeneratePackageOnBuild>False</GeneratePackageOnBuild>
     <Authors>Codaxy</Authors>
     <Company>Codaxy</Company>
-    <Version>3.3.0</Version>
+    <Version>3.4.0</Version>
   </PropertyGroup>
 
 	<ItemGroup>