app instance is now a topic

dancier · Dec 27, 2023 · dfe0889 · dfe0889
1 parent 80225fe
commit dfe0889
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/main/java/net/dancier/dancer/messaging/TopicConfiguration.java b/src/main/java/net/dancier/dancer/messaging/TopicConfiguration.java
@@ -10,8 +10,10 @@
 public class TopicConfiguration {
     @Bean
     public KafkaAdmin.NewTopics createTopics() {
-        NewTopic profileUpdated = new NewTopic("profile-updated", 1, (short) 1)
-        return new KafkaAdmin.NewTopics(profileUpdated);
+        NewTopic profileUpdated = new NewTopic("profile-updated", 1, (short) 1);
+        NewTopic appInstanceIdCreated = new NewTopic("app-instance-id-created", 1, (short) 1);
+
+        return new KafkaAdmin.NewTopics(profileUpdated, appInstanceIdCreated);
     }
 
 }