Skip to content

Commit 1996204

Browse files
yugasunYuga Sun
authored andcommitted
fix(scf): ckafka trigger support retry parameter
1 parent 0b52fbf commit 1996204

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/modules/scf/utils.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -122,6 +122,7 @@ const formatCkafkaTrigger = (region, funcInfo, inputs) => {
122122
triggerInputs.TriggerDesc = JSON.stringify({
123123
maxMsgNum: parameters.maxMsgNum,
124124
offset: parameters.offset,
125+
retry: parameters.retry,
125126
});
126127
triggerInputs.Enable = parameters.enable ? 'OPEN' : 'CLOSE';
127128
const triggerKey = `${triggerInputs.Type}-${triggerInputs.TriggerName}`;

0 commit comments

Comments
 (0)