update in application.*.conf

Author: Heng Cui

candyfloss/src/main/resources/application.dev.conf

@@ -1,25 +1,27 @@
 kafka {
   # Kafka and Kafka streams paramaerts, check https://docs.confluent.io/platform/current/installation/configuration/streams-configs.html for more details
-  application.id = "candyfloss-dev-app-id"
-  group.id = "cosmos.dev.candyflows-1"
-  bootstrap.servers = "localhost:9092"
+  application.id = "daisy.dev.candyfloss-tmp"
+  group.id = "daisy.dev.candyflows-1-tmp"
+  bootstrap.servers = "kafka.sbd.corproot.net:9093"
   acks = all
   enable.idempotence = true
-  schema.registry.url = "https://localhost:8081"
+  schema.registry.url = "https://schema-registry.zhh.sbd.corproot.net"
   key.serializer = "org.apache.kafka.common.serialization.StringSerializer"
   value.serializer = "org.apache.kafka.common.serialization.StringSerializer"
   metrics.recording.level = DEBUG
   compression.type = gzip
   replication.factor = 2
   num.stream.threads = 2
   probing.rebalance.interval.ms = 120000
-  # we may need to tune "metadata.max.age.ms" and "partition.assignment.strategy" for pattern subscription.
-  # metadata.max.age.ms = 30000
+
+  # the following settings could be relevant for behaviors when having multiple topics subscribed.
   # partition.assignment.strategy = "org.apache.kafka.clients.consumer.CooperativeStickyAssignor"
+  # max.partition.fetch.bytes = 128000
+  # metadata.max.age.ms = 300000
 }
 kstream {
-  input.topic.pattern = "dev.*\\.device-.*-raw"
-  input.topic.name = dev.device-json-raw-input
+  input.topic.pattern = "dev\\.device-yang(-[^-]+)?-raw"
+  input.topic.name = null
   discard.topic.name = dev.candyfloss-processing-discard # All messages that didn't match any step in the pipeline
   dlq.topic.name = dev.candyfloss-processing--dlq # Messages that encountered a Java exception during the processing
   normalization.statestore.cutoff.time.ms = 1800000 # 30 minutes

…main/resources/application.ietf.dev.conf …/main/resources/application.itm.dev.confcandyfloss/src/main/resources/application.ietf.dev.conf renamed to candyfloss/src/main/resources/application.itm.dev.conf candyfloss/src/main/resources/application.ietf.dev.conf renamed to candyfloss/src/main/resources/application.itm.dev.conf

@@ -15,6 +15,10 @@ kafka {
   num.stream.threads = 2
   auto.offset.reset = latest
   probing.rebalance.interval.ms = 120000
+
+  # partition.assignment.strategy = "org.apache.kafka.clients.consumer.CooperativeStickyAssignor"
+  # max.partition.fetch.bytes = 128000
+  # metadata.max.age.ms = 300000
 }
 kstream {
   input.topic.name = daisy.dev.device-json-raw

candyfloss/src/main/resources/application.prod.conf

@@ -13,6 +13,10 @@ kafka {
   replication.factor = 2
   num.stream.threads = 2
   probing.rebalance.interval.ms = 120000
+
+  # partition.assignment.strategy = "org.apache.kafka.clients.consumer.CooperativeStickyAssignor"
+  # max.partition.fetch.bytes = 128000
+  # metadata.max.age.ms = 300000
 }
 kstream {
   input.topic.name = prod.device-json-raw-input