diff --git a/src/service/event.batch.service.ts b/src/service/event.batch.service.ts
index 8526c26..996bf36 100644
--- a/src/service/event.batch.service.ts
+++ b/src/service/event.batch.service.ts
@@ -10,7 +10,6 @@ import { NftHolder } from 'models/NftHolder'
 import { TokenHolder } from 'models/TokenHolder'
 import { NftStake } from 'models/NftStake'
 import { IEventCfg } from "interface/IEventCfg";
-import { parse } from "path";
 
 let eventProcessers = {
   NftHolder: NftHolder,
@@ -62,7 +61,7 @@ export class EventBatchSvr {
           params.push(_param)
         } else {
           let _param = uninParams[uninParams.length - 1]
-          if (!_param || topicsSet.size > 1) {
+          if (!_param || !topicsSet.has(cfg.topic)) {
             _param = this.buildQueryParams(cfg, toBlock)
             uninParams.push(_param)
             topicsSet = new Set()