turn to static

confluentinc · Jul 6, 2020 · 8c33496 · 8c33496
1 parent 8d03103
commit 8c33496
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/ksqldb-common/src/main/java/io/confluent/ksql/util/KsqlConfig.java b/ksqldb-common/src/main/java/io/confluent/ksql/util/KsqlConfig.java
@@ -950,8 +950,8 @@ private static Set<String> sslConfigNames() {
     return sslConfig.names();
   }
 
-  public String getServiceId() {
+  public static String getServiceId(KsqlConfig ksqlConfig) {
     return ReservedInternalTopics.KSQL_INTERNAL_TOPIC_PREFIX
-        + this.getString(KsqlConfig.KSQL_SERVICE_ID_CONFIG);
+        + ksqlConfig.getString(KsqlConfig.KSQL_SERVICE_ID_CONFIG);
   }
 }
diff --git a/ksqldb-engine/src/main/java/io/confluent/ksql/query/QueryExecutor.java b/ksqldb-engine/src/main/java/io/confluent/ksql/query/QueryExecutor.java
@@ -162,7 +162,7 @@ public TransientQueryMetadata buildTransientQuery(
     final BlockingRowQueue queue = buildTransientQueryQueue(queryId, physicalPlan, limit);
 
     final String applicationId = addTimeSuffix(getQueryApplicationId(
-        ksqlConfig.getServiceId(),
+        KsqlConfig.getServiceId(ksqlConfig),
         ksqlConfig.getString(KsqlConfig.KSQL_TRANSIENT_QUERY_NAME_PREFIX_CONFIG),
         queryId
     ));
@@ -209,7 +209,7 @@ public PersistentQueryMetadata buildQuery(
     final String persistenceQueryPrefix =
         ksqlConfig.getString(KsqlConfig.KSQL_PERSISTENT_QUERY_NAME_PREFIX_CONFIG);
     final String applicationId = getQueryApplicationId(
-        ksqlConfig.getServiceId(),
+        KsqlConfig.getServiceId(ksqlConfig),
         persistenceQueryPrefix,
         queryId
     );

diff --git a/...db-rest-app/src/main/java/io/confluent/ksql/rest/server/execution/ListSourceExecutor.java b/...db-rest-app/src/main/java/io/confluent/ksql/rest/server/execution/ListSourceExecutor.java
@@ -228,7 +228,7 @@ private static SourceDescriptionWithWarnings describeSource(
           final String persistenceQueryPrefix =
               ksqlConfig.getString(KsqlConfig.KSQL_PERSISTENT_QUERY_NAME_PREFIX_CONFIG);
           final String applicationId = getQueryApplicationId(
-              ksqlConfig.getServiceId(),
+              KsqlConfig.getServiceId(ksqlConfig),
               persistenceQueryPrefix,
               queryId
           );