Skip to content

Commit f91c04e

Browse files
author
Andrew Choi
authored
Extract ClusterTopicManipulationService out of SingleClusterMonitor such that it can be instantiated as a separate service
Extract ClusterTopicManipulationService out of SingleClusterMonitor such that it can be instantiated as a separate service rather than part of the SingleClusterMonitor App Signed-off-by: Andrew Choi <[email protected]>
1 parent 41d2012 commit f91c04e

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

src/main/java/com/linkedin/xinfra/monitor/apps/SingleClusterMonitor.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010

1111
package com.linkedin.xinfra.monitor.apps;
1212

13-
import com.linkedin.xinfra.monitor.services.ClusterTopicManipulationServiceFactory;
1413
import com.linkedin.xinfra.monitor.services.ConsumeService;
1514
import com.linkedin.xinfra.monitor.services.ConsumerFactory;
1615
import com.linkedin.xinfra.monitor.services.ConsumerFactoryImpl;
@@ -68,13 +67,11 @@ public SingleClusterMonitor(Map<String, Object> props, String name) throws Excep
6867

6968
ProduceService produceService = new ProduceService(props, name);
7069
ConsumeService consumeService = new ConsumeService(name, topicPartitionResult, consumerFactory);
71-
Service clusterTopicManipulationService = new ClusterTopicManipulationServiceFactory(props, name).createService();
7270

7371
_allServices = new ArrayList<>(SERVICES_INITIAL_CAPACITY);
7472
_allServices.add(_topicManagementService);
7573
_allServices.add(produceService);
7674
_allServices.add(consumeService);
77-
_allServices.add(clusterTopicManipulationService);
7875
}
7976

8077
@Override

0 commit comments

Comments
 (0)