create process outbound topic if not created

samagra-comms · Aug 8, 2022 · 6e772e6 · 6e772e6
1 parent e8a625e
commit 6e772e6
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/main/java/com/uci/orchestrator/Application/AppConfigOrchestrator.java b/src/main/java/com/uci/orchestrator/Application/AppConfigOrchestrator.java
@@ -5,6 +5,7 @@
 import com.uci.utils.CampaignService;
 import com.uci.utils.kafka.ReactiveProducer;
 import io.fusionauth.client.FusionAuthClient;
+import org.apache.kafka.clients.admin.NewTopic;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.kie.api.io.Resource;
@@ -147,6 +148,11 @@ KafkaTemplate<String, String> kafkaTemplate() {
     	KafkaTemplate<String, String> kafkaTemplate = new KafkaTemplate<>(producerFactory());
     	return (KafkaTemplate<String, String>) kafkaTemplate;
     }
+
+    @Bean
+    public NewTopic topic1() {
+        return new NewTopic(processOutboundTopic, 1, (short) 1);
+    }
 
 //    @Bean
 //    public HealthService healthService() {