This release upgrades the build environment and modernizes the codebase to ensure compatibility with newer Gradle, Flink, and Java versions. It removes deprecated APIs, updates dependencies, and aligns the project with current ecosystem standards.

Note: A minimum of JRE 17 is now required to build and run the project.

Changes

• flink upgrade to 2.1.0 #84 @tilakraj94 @scottf
  • Build and Dependency Updates
  • Upgraded Gradle wrapper to 8.10
  • Upgraded JaCoCo to 0.8.12
  • Removed deprecated Gradle APIs
  • Increased Java version from 11 → 17

REPLACED BY 3.0.1

Features

• Add Consumer Name Support to JetStreamSubjectConfiguration #78 @tilakraj94 @scottf
• remove restrictions on inactive threshold #79 @tilakraj94
• Clarify Durable, Add Consumer Name Prefix #80 @scottf

Testing

• More test coverage. #77 @scottf
• Adding unit test coverage #81 @scottf

Changes

• Support ackWait #73 @tilakraj94
• Tuning and Tests #74 @scottf

Version Note Regarding 2.1.4 and 2.2.0

There was technically a violation of semver. An api that was renamed in 2.1.4 should only have been deprecated.
2.2.0 fixes this by changing the name back.

In JetStreamSubjectConfiguration.Builder, ackMode() was incorrectly renamed to ackBehavior()

This has been "fixed" as in

Bob Slydell: "We, uh, we fixed the glitch. So he won't be receiving a paycheck anymore, so it'll just work itself out naturally."

Very sorry, we appreciate your understanding, at least we didn't steal your stapler.

• Make readers lazy init. #65 @scottf
• Refactor ackMode to AckBehavior #67 @tilakraj94
• Additional documenting of explicit behavior. #69 @scottf
• Fix #68 High CPU #70 @scottf
• Don't make snapshot until a message has been received. #71 @scottf

• Make readers lazy init. #65 @scottf

This is a re-release of 2.1.1 to test the migration to Sonatype Central from legacy Sonatype. The original notes are as follows:

2.1.1 JetStream Support

• This release contains the brand new implementation of JetStreamSink and JetStreamSource.
• It provide a major overhaul and cleanup of the organization of class files.
• It provides support for JSON and YAML file configuration for sinks and sources.
• It updates and adds examples with plenty of comments.
• The README has been updated with everything you need to get started.

• This release contains the brand new implementation of JetStreamSink and JetStreamSource.
• It provide a major overhaul and cleanup of the organization of class files.
• It provides support for JSON and YAML file configuration for sinks and sources.
• It updates and adds examples with plenty of comments.
• The README has been updated with everything you need to get started.

• Add streamName to NatsJetStreamSourceBuilder #32 @miklosbarabas
• Revert to manual ack #33 @scottf
• Remove redundant NatSubjectStateSplitState class #35 @scottf
• fixes consumer 409 deleted #36 @tilakraj94
• assign all splits correctly to source readers #37 @tilakraj94
• Clear source reader state on checkpointing #39 @tilakraj94
• Add tests to demonstrate getting headers from the source message. #40 @scottf
• Add tests for NatsSubjectSplitReader class #43 @somratdutta
• Entire message as payload #44 @scottf
• Add tests for classes, add null checks #46 @somratdutta
• Example 2 #48 @scottf
• Generify NatsSourceEnumerator #49 @scottf
• Add Support for NATS Message Serialization/De-Serialization #50 @tilakraj94
• Add multiple messages to verify order #51 @tilakraj94

JetStream

• JetStreamOption support #21 @scottf

Tests

• Fix Assertion Logic in Flink Source Tests and Validate End-to-End Data Flow with Improved Cleanup #19 @somratdutta

Misc

• Address sbom vulnerabilities #20 @scottf