juliusgeo · Oct 13, 2026 · Oct 13, 2026 · Oct 13, 2026 · Oct 13, 2026 · Oct 13, 2026
diff --git a/api-contracts/v1/streams.proto b/api-contracts/v1/streams.proto
@@ -10,6 +10,7 @@ service V1Streams {
     rpc Publish(PublishStreamMessageRequest) returns (PublishStreamMessageResponse) {}
     rpc Subscribe(SubscribeStreamRequest) returns (stream StreamMessage) {}
     rpc GetTopicMetadata(GetStreamTopicMetadataRequest) returns (StreamTopicMetadata) {}
+    rpc Reset(ResetStreamTopicRequest) returns (ResetStreamTopicResponse) {}
 }
 
 message PublishStreamMessageRequest {
@@ -61,3 +62,10 @@ message StreamTopicMetadata {
     // when the newest retained message was stored; unset when none is retained
     google.protobuf.Timestamp last_published_at = 6;
 }
+
+message ResetStreamTopicRequest {
+    string namespace = 1;
+    string topic = 2;
+}
+
+message ResetStreamTopicResponse {}
diff --git a/cmd/hatchet-migrate/migrate/migrations/20261013133204_v1_0_172.sql b/cmd/hatchet-migrate/migrate/migrations/20261013133204_v1_0_172.sql
@@ -0,0 +1,10 @@
+-- +goose Up
+-- +goose StatementBegin
+-- subscribers without a cursor start after this offset (see ResetStreamTopic)
+ALTER TABLE v1_stream_topic ADD COLUMN starting_offset BIGINT NOT NULL DEFAULT 0;
+-- +goose StatementEnd
+
+-- +goose Down
+-- +goose StatementBegin
+ALTER TABLE v1_stream_topic DROP COLUMN starting_offset;
+-- +goose StatementEnd
diff --git a/examples/typescript/durable-streams/run.ts b/examples/typescript/durable-streams/run.ts
diff --git a/examples/typescript/durable-streams/worker.ts b/examples/typescript/durable-streams/worker.ts
diff --git a/examples/typescript/durable-streams/workflow.ts b/examples/typescript/durable-streams/workflow.ts
diff --git a/examples/typescript/e2e-worker.ts b/examples/typescript/e2e-worker.ts
diff --git a/frontend/docs/content/docs/reference/changelog/typescript.mdx b/frontend/docs/content/docs/reference/changelog/typescript.mdx
@@ -6,6 +6,12 @@ description: "Release notes for every Hatchet TypeScript SDK release, newest fir
 
 {/* AUTOGENERATED — do not edit. Run `task sync-changelog` to regenerate from sdks/typescript/CHANGELOG.md */}
 
+## v1.38.0 - 2026-10-13
+
+### Added
+
+- Added `hatchet.streams.reset(topic, { namespace })`, after which `events()` calls without a cursor start after the topic's latest message. Readers already iterating, and calls with a cursor, are unaffected.
+
 ## v1.37.0 - 2026-10-07
 
 ### Added

diff --git a/frontend/docs/content/docs/reference/typescript/feature-clients/streams.mdx b/frontend/docs/content/docs/reference/typescript/feature-clients/streams.mdx
@@ -16,7 +16,8 @@ readers can resume from a cursor.
 
 ##### `events()`
 
-Yields topic's messages after options.cursor, or from the oldest retained.
+Yields topic's messages after options.cursor, or from the oldest retained
+(or, once the topic is reset, after the reset).
 If the connection drops, it resubscribes from the last message yielded, so
 nothing is skipped or repeated. Ends when the server hangs up an idle
 subscription, options.signal aborts, or the caller stops iterating; throws
@@ -52,6 +53,25 @@ Returns
 
 `Promise`\<`void`\>
 
+<a id="reset"></a>
+
+##### `reset()`
+
+Makes events() calls without a cursor start after the topic's latest
+message. Readers already iterating, and any call with a cursor, are
+unaffected.
+
+Parameters
+
+| Parameter  | Type                                         | Description                 |
+| ---------- | -------------------------------------------- | --------------------------- |
+| `topic`    | `string`                                     | the topic to reset          |
+| `options?` | `Pick`\<`StreamCallOptions`, `"namespace"`\> | optional namespace override |
+
+Returns
+
+`Promise`\<`void`\>
+
 <a id="topicmetadata"></a>
 
 ##### `topicMetadata()`