For installation instructions check out the getting started guide.
NOTE: This is a release candidate, you can download a binary from this page.
Fixed
- Fixed a bug with the
redpanda_migrator_offsets
input and output where the consumer group update migration logic based on timestamp lookup should no longer skip ahead in the destination cluster. This should enforce at-least-once delivery guarantees. (@mihaitodor) - The
redpanda_migrator_bundle
output no longer drops messages if either theredpanda_migrator
or theredpanda_migrator_offsets
child output throws an error. Connect will keep retrying to write the messages and apply backpressure to the input. (@mihaitodor)
Added
- Added a lint rule to verify field
private_key
for thesnowflake_streaming
output is in PEM format. (@rockwotj) - New
mongodb_cdc
input for change data capture (CDC) over MongoDB collections. (@rockwotj) - Field
is_high_watermark
added to theredpanda_migrator_offsets
output. (@mihaitodor) - Metadata field
kafka_is_high_watermark
added to theredpanda_migrator_offsets
input. (@mihaitodor)
Fixed
- Fix an issue in the
snowflake_streaming
output when the user manually evolves the schema in their pipeline that could lead to elevated error rates in the connector. (@rockwotj)
Changed
- Output
snowflake_streaming
has additional logging and debug information when errors arise. (@rockwotj)
The full change log can be found here.