because if I do

const stream = new KinesisStream(stack, "Stream", {
    consumers: {
      consumer1: {
        function: {
          handler: "functions/lambda.handler",
          timeout: 5,
          retryAttempts: 5
        },
      },
    },
  });

with the function that will timeout

export const handler: any = async (event) => {
  console.log("Run");
  await sleep(20000);
};

function sleep(ms) {
  return new Promise((resolve) => {
    setTimeout(resolve, ms);
  });
}

it times out, but doesn't retry - same goes for throwing errors, no retry

I worked once with Kinesis and one of the reasons I moved to SQS was that I think it’s easier to work with the retries and dead-letter queues… if it fits to your case I’d say to go for that as well

@sforman is this happening on

sst start

or after u

sst deploy

?