Skip to content

Conversation

@ulemons
Copy link
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 payload change (new metadata field) with minimal logic changes; main risk is downstream consumers that assume a fixed message schema.

Overview
Activity messages emitted from insertActivities now include a metadata.commit_timestamp field (ISO timestamp) before being sent to the activities queue/Kafka, and logs were updated to include the new timestamp when dispatching.

Written by Cursor Bugbot for commit 5652a17. 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
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.

3 participants