add topic creation to controller

spotguides · Nov 5, 2019 · ec589cf · ec589cf
1 parent dbbfb5c
commit ec589cf
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/main/java/com/banzaicloud/spotguide/KafkaController.java b/src/main/java/com/banzaicloud/spotguide/KafkaController.java
@@ -1,7 +1,9 @@
 package com.banzaicloud.spotguide;
 
+import org.apache.kafka.clients.admin.NewTopic;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.kafka.annotation.KafkaListener;
@@ -43,4 +45,9 @@ public List<String> listMessages() {
     public void consume(String message) {
         messages.add(message);
     }
+
+    @Bean
+    public NewTopic newTopic() {
+        return new NewTopic(BOOT_TOPIC, 1, (short) 1);
+    }
 }