feat(lambda): support for Provisioned Pollers

[roger-zhangg]

Reason for this change

Lambda is introducing a new property in Event Sources named ProvisionedPollerConfig to set provisioned pollers that read from the event sources. When specified, it allows control over the minimum and maximum number of pollers that can be provisioned to process events from the source.

This feature is currently supported for MSK and Self-managed Kafka event sources.

Description of changes

This new property can be opted in by setting the ProvisionedPollerConfig field while creating event sources. The example of setting ProvisionedPollerConfig for is shown below:

fn.addEventSource(new sources.ManagedKafkaEventSource(
  {
    clusterArn,
    topic: kafkaTopic,
    startingPosition: lambda.StartingPosition.TRIM_HORIZON,
    provisionedPollerConfig: {
      minimumPollers: 1,
      maximumPollers: 3,
    },
  }))

Description of how you validated changes

Have added unit test and integration test to validate the implementation

Checklist

• My code adheres to the CONTRIBUTING GUIDE and DESIGN GUIDELINES

---

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache-2.0 license

[codecov]

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 77.17%. Comparing base (6317a2a) to head (7c29f63).
Report is 9 commits behind head on main.

Additional details and impacted files

@@            Coverage Diff             @@
##             main   #32205      +/-   ##
==========================================
- Coverage   77.18%   77.17%   -0.01%     
==========================================
  Files         105      105              
  Lines        7161     7169       +8     
  Branches     1312     1315       +3     
==========================================
+ Hits         5527     5533       +6     
- Misses       1454     1455       +1     
- Partials      180      181       +1     

Flag	Coverage Δ
suite.unit	77.17% <ø> (-0.01%)	⬇️

Flags with carried forward coverage won't be shown. Click here to find out more.

Components	Coverage Δ
packages/aws-cdk	77.17% <ø> (-0.01%)	⬇️

---- 🚨 Try these New Features:

• Flaky Tests Detection - Detect and resolve failed and flaky tests
• JS Bundle Analysis - Avoid shipping oversized bundles

Pull request has been modified.

[GavinZZ]

nit comments

Pull request has been modified.

[GavinZZ]

@mergify update

[mergify]

update

❌ Mergify doesn't have permission to update

For security reasons, Mergify can't update this pull request. Try updating locally.
GitHub response: refusing to allow a GitHub App to create or update workflow .github/workflows/codecov.yml without workflows permission

Pull request has been modified.

[aws-cdk-automation]

AWS CodeBuild CI Report

• CodeBuild project: AutoBuildv2Project1C6BFA3F-wQm2hXv2jqQv
• Commit ID: 00f6e68
• Result: SUCCEEDED
• Build Logs (available for 30 days)

Powered by github-codebuild-logs, available on the AWS Serverless Application Repository

[mergify]

Thank you for contributing! Your pull request will be updated from main and then merged automatically (do not update manually, and be sure to allow changes to be pushed to your fork).

Pull request has been modified.