Merge branch '7.7.x' into master by trnguyencflt

confluentinc · May 29, 2024 · a04ed80 · a04ed80
2 parents da1d8d4 + 46ec76e
commit a04ed80
Showing 1 changed file with 4 additions and 9 deletions.
diff --git a/core/src/main/java/io/confluent/rest/ApplicationServer.java b/core/src/main/java/io/confluent/rest/ApplicationServer.java
@@ -30,7 +30,6 @@
 import java.util.StringTokenizer;
 import java.util.concurrent.BlockingQueue;
 import org.apache.kafka.common.MetricName;
-import org.apache.kafka.common.config.ConfigException;
 import org.apache.kafka.common.metrics.Gauge;
 import org.apache.kafka.common.metrics.Metrics;
 import org.eclipse.jetty.alpn.server.ALPNServerConnectionFactory;
@@ -132,35 +131,31 @@ public List<Application<?>> getApplications() {
 
   private void attachMetricsListener(String listenerName, Metrics metrics,
       Map<String, String> tags) {
-    boolean hasNetworkConnector = false;
     for (NetworkTrafficServerConnector connector : connectors) {
       if (Objects.equals(connector.getName(), listenerName)) {
         MetricsListener metricsListener = new MetricsListener(metrics, "jetty", tags);
         connector.addNetworkTrafficListener(metricsListener);
         log.info("Registered {} to connector of listener: {}",
             metricsListener.getClass().getSimpleName(), listenerName);
-        hasNetworkConnector = true;
       }
     }
-    if (!hasNetworkConnector) {
-      throw new ConfigException("No network connector found for listener: " + listenerName);
+    if (connectors.isEmpty()) {
+      log.warn("No network connector configured for listener: {}", listenerName);
     }
   }
 
   private void attachNetworkTrafficRateLimitListener(RestConfig appConfig, String listenerName) {
     if (appConfig.getNetworkTrafficRateLimitEnable()) {
-      boolean hasNetworkConnector = false;
       for (NetworkTrafficServerConnector connector : connectors) {
         if (Objects.equals(connector.getName(), listenerName)) {
           NetworkTrafficListener rateLimitListener = new RateLimitNetworkTrafficListener(appConfig);
           connector.addNetworkTrafficListener(rateLimitListener);
           log.info("Registered {} to connector of listener: {}",
               rateLimitListener.getClass().getSimpleName(), listenerName);
-          hasNetworkConnector = true;
         }
       }
-      if (!hasNetworkConnector) {
-        throw new ConfigException("No network connector found for listener: " + listenerName);
+      if (connectors.isEmpty()) {
+        log.warn("No network connector configured for listener: {}", listenerName);
       }
     }
   }