v0.0.10

What's new

• Configurable Flink Traceability using the traceConfiguration field
• Configurable non-checkpoint flushing numMessagesToBuffer and flushIntervalMillis parameters
• Fixed bug with lingering XINFO calls after killing a job with a Redis Source.

v0.0.7

• TLS & mTLS support
• Fixes issue with metrics polling after a Redis outage

v0.0.5

• Handling default authentication credentials
• Assigning splits based on parallelism
• Issue with XPENDING trying to use $ as it's start ID.

v0.0.4

• Adding ability to send erroneously deserialized messages to a DLQ
• Adding ability to have sink writer flush between commits

v0.0.3

• fixing null reference exception when no entries have been read by the split yet
• cleaning up partition config

v0.0.2

Features

• Adds new generic object serialization for messages in Partitioned Redis Streams
• Decreases verbosity of info logging
• Set required flink version to 1.19.0