Skip to content

KCL consumer periodically commits checkpoint without checking configured checkpoint mode #148

@dirkbonhomme

Description

@dirkbonhomme

The KclMessageDrivenChannelAdapter will periodically commit the checkpoint without checking the configured checkpoint mode.

Notice how it automatically tries to commit after processing a single record:
https://github.com/spring-projects/spring-integration-aws/blob/master/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java#L320

While it does correctly check for the checkpoint mode after processing a batch:
https://github.com/spring-projects/spring-integration-aws/blob/master/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java#L331

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions