fix(quickstart): fix bad configurations (#131)

Resolves: #131
streamthoughts · Mar 16, 2021 · ff02e30 · ff02e30
1 parent ccb2cf7
commit ff02e30
Show file tree

Hide file tree

Showing 5 changed files with 19 additions and 21 deletions.
diff --git a/azkarra-examples/src/main/resources/application.conf b/azkarra-examples/src/main/resources/application.conf
@@ -1,5 +1,5 @@
 azkarra {
-  // Configure default properties for Kafka streams applications
+
   context {
     // configuration used by ComplexWordCountTopoloy
     topology.topic.source="streams-plaintext-input"

diff --git a/...ra-quickstart-java/src/main/resources/archetype-resources/src/main/java/StreamingApp.java b/...ra-quickstart-java/src/main/resources/archetype-resources/src/main/java/StreamingApp.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2019-2020 StreamThoughts.
+ * Copyright 2019-2021 StreamThoughts.
  *
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements. See the NOTICE file distributed with

diff --git a/...uickstart-java/src/main/resources/archetype-resources/src/main/resources/application.conf b/...uickstart-java/src/main/resources/archetype-resources/src/main/resources/application.conf
@@ -1,12 +1,5 @@
 azkarra {
   context {
-    // Default configs for kafka streams instances
-    streams {
-      bootstrap.servers = "localhost:9092"
-      default.key.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde"
-      default.value.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde"
-    }
-
     // Create source topics before starting Kafka Streams.
     auto.create.topics.enable = true
 
@@ -20,10 +13,16 @@ azkarra {
       topic = "_azkarra-streams-monitoring"
       // The period the interceptor should use to send a streams state event (in milliseconds)
       interval.ms = 10000
-
     }
   }
 
+  // Global configuration for all Kafka Streams instances
+  streams {
+    bootstrap.servers = "localhost:9092"
+    default.key.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde"
+    default.value.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde"
+  }
+
   // List of components to auto-registered into context;
   components = [ ]
 
@@ -47,7 +46,7 @@ azkarra {
     rest.extensions.enable = true
     port = 8080
     headless = false
-    enable.ui = true
+    webui.enable = true
     // These information will be exposes through the http endpoint GET /info
     info {
       app {

diff --git a/...-quickstart-kotlin/src/main/resources/archetype-resources/src/main/kotlin/StreamingApp.kt b/...-quickstart-kotlin/src/main/resources/archetype-resources/src/main/kotlin/StreamingApp.kt
@@ -1,5 +1,5 @@
 /*
- * Copyright 2019-2020 StreamThoughts.
+ * Copyright 2019-2021 StreamThoughts.
  *
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements. See the NOTICE file distributed with

diff --git a/...ckstart-kotlin/src/main/resources/archetype-resources/src/main/resources/application.conf b/...ckstart-kotlin/src/main/resources/archetype-resources/src/main/resources/application.conf
@@ -1,12 +1,5 @@
 azkarra {
   context {
-    // Default configs for kafka streams instances
-    streams {
-      bootstrap.servers = "localhost:9092"
-      default.key.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde"
-      default.value.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde"
-    }
-
     // Create source topics before starting Kafka Streams.
     auto.create.topics.enable = true
 
@@ -20,10 +13,16 @@ azkarra {
       topic = "_azkarra-streams-monitoring"
       // The period the interceptor should use to send a streams state event (in milliseconds)
       interval.ms = 10000
-
     }
   }
 
+  // Global configuration for all Kafka Streams instances
+  streams {
+    bootstrap.servers = "localhost:9092"
+    default.key.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde"
+    default.value.serde = "org.apache.kafka.common.serialization.Serdes$StringSerde"
+  }
+
   // List of components to auto-registered into context;
   components = [ ]
 
@@ -47,7 +46,7 @@ azkarra {
     rest.extensions.enable = true
     port = 8080
     headless = false
-    enable.ui = true
+    webui.enable = true
     // These information will be exposes through the http endpoint GET /info
     info {
       app {