From dfe0889ebd6811c2cf3bf866baa98efbdef215c7 Mon Sep 17 00:00:00 2001 From: Marc Gorzala Date: Wed, 27 Dec 2023 06:56:45 +0100 Subject: [PATCH] app instance is now a topic --- .../net/dancier/dancer/messaging/TopicConfiguration.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/net/dancier/dancer/messaging/TopicConfiguration.java b/src/main/java/net/dancier/dancer/messaging/TopicConfiguration.java index 2ad448c..bc28287 100644 --- 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); } }