Skip to main content
Version: 14.3.0

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