Skip to content

feat: add metadata timestamp (CM-868)#3814

Merged
ulemons merged 1 commit intomainfrom
feat/kafka-metadata-activities
Feb 4, 2026
Merged

feat: add metadata timestamp (CM-868)#3814
ulemons merged 1 commit intomainfrom
feat/kafka-metadata-activities

Conversation

@ulemons
Copy link
Copy Markdown
Contributor

@ulemons ulemons commented Feb 2, 2026

Summary

Add metadata.commit_timestamp to the Kafka activities topic payload to align with the structure of other
topics coming from Sequin.

Background

All topics from Sequin have this structure:

{
  "metadata": {
    "commit_timestamp": "2025-03-17T02:51:12.741208Z"
  },
  "record": { ... }
}

However, the activities topic is pushed directly by data-sink-worker (not via Sequin), so it was missing the
metadata field.

Changes:

Also on the activities message now we have the structure:

{
    .....,
    "metadata": {
      "commit_timestamp": "2025-03-17T02:51:12.741208Z"
    },
}

Note

Low Risk
Small, additive change to the Kafka message payload shape; main risk is downstream consumers that strictly validate the schema or message size expectations.

Overview
Activity messages dispatched by insertActivities now include a metadata object with commit_timestamp (ISO string) in the payload sent via QueueEmitter, and logging was updated to include the emitted commit timestamp.

Written by Cursor Bugbot for commit 4ae9028. This will update automatically on new commits. Configure here.

@ulemons ulemons self-assigned this Feb 2, 2026
@ulemons ulemons added the Feature Created by Linear-GitHub Sync label Feb 2, 2026
@ulemons ulemons marked this pull request as ready for review February 2, 2026 14:51
@ulemons ulemons requested a review from themarolt February 2, 2026 14:51
@ulemons ulemons force-pushed the feat/kafka-metadata-activities branch from 5652a17 to 4ae9028 Compare February 4, 2026 11:17
Copy link
Copy Markdown

@cursor cursor Bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Cursor Bugbot has reviewed your changes and found 1 potential issue.

Comment thread services/libs/data-access-layer/src/activities/insert.ts
@ulemons ulemons merged commit ec6119a into main Feb 4, 2026
16 checks passed
@ulemons ulemons deleted the feat/kafka-metadata-activities branch February 4, 2026 16:19
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Feature Created by Linear-GitHub Sync

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants