File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed
Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -199,16 +199,21 @@ public abstract class AbstractDispatchTask<E extends Comparable & EntifyIdInterf
199199
200200``` java
201201// 继承AbstractDispatchTask的抽象类,对Kafka集群进行负载均衡执行
202- public abstract class AbstractClusterPhyDispatchTask extends AbstractDispatchTask<ClusterPhy > {
202+ public abstract class AbstractClusterPhyDispatchTask extends AbstractDispatchTask<ClusterPhy > {
203+
203204 // 执行被分配的任务,具体由子类实现
204- protected abstract TaskResult processSubTask (ClusterPhy clusterPhy , long triggerTimeUnitMs ) throws Exception ; // 返回所有的Kafka集群
205+ protected abstract TaskResult processSubTask (ClusterPhy clusterPhy , long triggerTimeUnitMs ) throws Exception ;
206+
207+ // 返回所有的Kafka集群
205208 @Override
206209 public List<ClusterPhy > listAllTasks () {
207210 return clusterPhyService. listAllClusters();
208211 }
212+
209213 // 执行被分配给该KS主机的Kafka集群任务
210214 @Override
211215 public TaskResult processTask (List<ClusterPhy > subTaskList , long triggerTimeUnitMs ) { // ... }
216+
212217}
213218```
214219
You can’t perform that action at this time.
0 commit comments