Skip to content

[FLINK-39599][Connectors/Kinesis] Emit pendingRecords metric in Kinesis connector.#246

Open
dwangatt wants to merge 1 commit into
apache:mainfrom
dwangatt:flink-39599
Open

[FLINK-39599][Connectors/Kinesis] Emit pendingRecords metric in Kinesis connector.#246
dwangatt wants to merge 1 commit into
apache:mainfrom
dwangatt:flink-39599

Conversation

@dwangatt
Copy link
Copy Markdown

@dwangatt dwangatt commented May 4, 2026

Purpose of the change

Update Kinesis connector to emit pendingRecords.

Verifying this change

Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing

(Please pick either of the following options)

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

(example:)

  • Added integration tests for end-to-end deployment
  • Added unit tests
  • Manually verified by running the Kinesis connector on a local Flink cluster.

Significant changes

(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterwards, for convenience.)

  • Dependencies have been added or upgraded
  • Public API has been changed (Public API is any class annotated with @Public(Evolving))
  • Serializers have been changed
  • New feature has been introduced
    • If yes, how is this documented? (not applicable / docs / JavaDocs / not documented)

@boring-cyborg
Copy link
Copy Markdown

boring-cyborg Bot commented May 4, 2026

Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant