Updating cluster api props - scheduler

Signed-off-by: muralibasani <[email protected]>
Aiven-Open · Oct 13, 2023 · 4edc347 · 4edc347
1 parent a565f29
commit 4edc347
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/cluster-api/src/main/java/io/aiven/klaw/clusterapi/config/SchedulerConfig.java b/cluster-api/src/main/java/io/aiven/klaw/clusterapi/config/SchedulerConfig.java
@@ -14,6 +14,9 @@ public class SchedulerConfig {
   @Value("${klaw.schemainfo.scheduler.threadcount:4}")
   private int poolSize;
 
+  @Value("${klaw.topics.scheduler.threadcount:4}")
+  private int poolSizeTopics;
+
   @Bean(name = "resetSchemaCacheTaskExecutor")
   public Executor threadPoolTaskExecutor() {
     ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
@@ -24,7 +27,7 @@ public Executor threadPoolTaskExecutor() {
   @Bean(name = "resetTopicsCacheTaskExecutor")
   public Executor topicsThreadPoolTaskExecutor() {
     ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
-    threadPoolTaskExecutor.setCorePoolSize(poolSize);
+    threadPoolTaskExecutor.setCorePoolSize(poolSizeTopics);
     return threadPoolTaskExecutor;
   }
 }
diff --git a/cluster-api/src/main/resources/application.properties b/cluster-api/src/main/resources/application.properties
@@ -96,4 +96,9 @@ klaw.clusters.aiven.servicedetails.api=https://api.aiven.io/v1/project/projectNa
 # scheduler for schema cache update runs at default 12 am UTC everyday
 klaw.schemainfo.cron.expression=0 0 0 * * ?
 klaw.schemainfo.cron.expression.timezone=UTC
-klaw.schemainfo.scheduler.threadcount=4
+klaw.schemainfo.scheduler.threadcount=4
+
+# scheduler for topics cache update runs at default 12 am UTC everyday
+klaw.topics.cron.expression=0 0 0 * * ?
+klaw.topics.cron.expression.timezone=UTC
+klaw.topics.scheduler.threadcount=4