[FLINK-37908] Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts

[digitalpoetry]

Purpose of the change

Resolve race condition on automated restarts of Flink apps with an EFO-enabled KinesisStreamsSource.

Verifying this change

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

This change is aligned with a previously implemented fix for the same issue observed within the FlinkKinesisConsumer connector:

• https://issues.apache.org/jira/browse/FLINK-24431
• FLINK-24431 [flink-connector-kinesis] Stop consumer deregistration when EAGER EFO configured. flink#17417

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]

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

[davidradl]

@digitalpoetry you have format violations in CI checks .

[digitalpoetry]

For some reason, I was able to build on my work machine, but not my personal machine 🤷 I'll need to look into that...
Fixed now, thank you @davidradl