Changelog
All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.
[0.5.0] - 2025-09-11
Changed
- Align implementation with stream-processor and ensure multi-replica setup works
- Emit partition alongside consumer lag in cp metadata
- Use consumer lag wrapper for feedback metadata
Documentation
- Review typo and improve sentence
- Add documentation folder
Fixed
- Update rust crate mongodb to 3.3.0
- Update rust crate uuid to 1.18.1
- Update rust crate secret_rs to 0.4.2
- Update rust crate thiserror to 2.0.16
- Update rust crate mongodb to 3.2.5
[0.4.0] - 2025-08-19
Added
- Add tracking of consumer lag as feedback metadata
- Define service startup behavior when connection with control plane is enabled
- Add app_name configuration option to name mongodb driver
Fixed
- Update rust crate thiserror to 2.0.15
- Update rust crate tower-http to 0.6.6
- Update rust crate thiserror to 2.0.14
- Update rust crate anyhow to 1.0.99
- Ensure startup behavior is triggered when both control plane config and binding file are provided
- Update rust crate uuid to 1.18.0
- Ensure proper reporting of consumer lag and consumer queue metrics
[0.3.0] - 2025-07-25
Added
- Introduce processing and consumer related metrics
- Allow delete operations without before value set
- New update/replace strategy + settings to control mode via config
- Add configs to work with local farm-data
Changed
- Ensure that consumption from topic partition is resumed only when the topic was set to resume state
- Fine tune consumer queued.min.messages default value
Fixed
- Update rust crate uuid to 1.17.0
- Update rust crate bson to 2.15.0
- Update rust crate axum to 0.8.4
[0.2.0] - 2025-05-05
Added
- One transaction for all batches
- Handle transaction abort
- Write with transacion
- Write to mongo in batches of message WIP
- Messages are batched and filtered
- Update key conversion
- Setup manual commit
- Key supports both id and _id
- Input message has id in key
- Rebalance
- Filtering is from key
- Run stream + custom errors
- Handle message operations
- Setup kafka conusmer and mongo client
Changed
- Service review
- Transaction ending is generalized
- Handle process result
- Remove unused
- Refactor
- Remove println
- Rename tests and file
- Generalize write one / write all batches
- Filter out invalid messages
- Key and payload are serialized before entering process
- Rename folders
- Move processor to mongo dir
- Refactor
Fixed
- Deserialize stringified documents WIP
- Add partitions + topic is random
- Add assertions on offsets
- Add utils
- Add utils
- Alternate input messages
- Refactor
- Refactor
- Add kafka to docker compose
- Handle mongodb debezium interface