Skip to content

Commit 62db15a

Browse files
committed
fix(trigger): ckafka parameter typo
1 parent 6805a1d commit 62db15a

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/modules/triggers/ckafka.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ export default class CkafkaTrigger {
4949
maxMsgNum: parameters?.maxMsgNum ?? 100,
5050
offset: parameters?.offset ?? 'latest',
5151
retry: parameters?.retry ?? 10000,
52-
timeOut: parameters?.timeOut ?? 60,
52+
timeOut: parameters?.timeout ?? 60,
5353
}),
5454
Enable: parameters?.enable ? 'OPEN' : 'CLOSE',
5555
};

src/modules/triggers/interface/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ export interface CkafkaTriggerInputsParams extends TriggerInputsParams {
6060
maxMsgNum?: number;
6161
offset?: number;
6262
retry?: number;
63-
timeOut?: number;
63+
timeout?: number;
6464
enable?: boolean;
6565
}
6666

0 commit comments

Comments
 (0)