hugocasa
ec20d76216
feat: add auto_commit option to Kafka triggers with advanced UI badges ( #8317 )
...
* feat: add auto_commit option to Kafka triggers with manual commit API
Add ability to disable auto-commit on Kafka triggers so users can
manually commit offsets after processing messages. This prevents
message loss when processing fails.
Changes:
- Add `auto_commit` column to kafka_trigger table (default true)
- Add POST /kafka_triggers/commit_offsets/{path} endpoint using
BaseConsumer with manual assign() to avoid rebalance
- Enrich trigger_info payload with partition and offset fields
- Conditionally commit based on auto_commit setting
- Add auto-commit toggle to frontend Kafka trigger config
- Add commitKafkaOffsets helpers to Python and TypeScript SDKs
- Add integration tests for auto_commit DB defaults
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* feat: use DB-based pending commits for kafka manual offset commit
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com >
* feat: pass trigger_path to all v2 preprocessors, secure commit_offsets endpoint, fix commit semantics
- Add trigger_path to v2 preprocessor event for all trigger types (kafka, nats, sqs, mqtt, gcp, postgres, websocket, http, email)
- Secure commit_offsets endpoint: infer trigger from job token (OptJobAuthed) instead of requiring trigger path parameter
- Fix auto_commit: only commit offset after successful job push
- Fix pending commits: commit offset+1 (Kafka semantics) and use CommitMode::Sync
- Update TS/Python clients and frontend preprocessor templates
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* feat: add advanced section badges and reorganize kafka trigger settings
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* fix: remove dead wm_trigger assertions from kafka e2e test
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* sqlx
* refactor: remove unused advancedCollapsed state from all trigger editors
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* update ref
* chore: update ee-repo-ref to ed2c9d360e6fab866b9744cc79f50038d1fc7152
This commit updates the EE repository reference after PR #452 was merged in windmill-ee-private.
Previous ee-repo-ref: 5b31116a1d5a042c6a780732901cfd89584d1773
New ee-repo-ref: ed2c9d360e6fab866b9744cc79f50038d1fc7152
Automated by sync-ee-ref workflow.
* fix: use path-based auth for kafka commit_offsets endpoint
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com >
* chore: update ee-repo-ref to fcd3ea52b0cc94fbe1159baf662a38da947456de
This commit updates the EE repository reference after PR #457 was merged in windmill-ee-private.
Previous ee-repo-ref: b3a5c33c92cb1b2caf7a65986d71da291ff72a35
New ee-repo-ref: fcd3ea52b0cc94fbe1159baf662a38da947456de
Automated by sync-ee-ref workflow.
---------
Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com >
Co-authored-by: windmill-internal-app[bot] <windmill-internal-app[bot]@users.noreply.github.com>
Co-authored-by: Ruben Fiszel <ruben@windmill.dev >
2026-03-12 14:00:30 +00:00
..
2025-06-17 19:49:00 +02:00
2025-04-20 01:19:02 +02:00
2025-04-20 01:19:02 +02:00
2025-03-20 16:45:21 +01:00
2025-03-20 16:45:21 +01:00
2025-02-25 16:35:29 +01:00
2025-02-25 16:35:29 +01:00
2025-02-27 14:37:39 +01:00
2025-02-27 14:37:39 +01:00
2025-03-19 19:41:10 +01:00
2025-03-19 19:41:10 +01:00
2025-03-04 23:52:47 +01:00
2025-03-04 23:52:47 +01:00
2025-03-04 23:52:47 +01:00
2025-03-04 23:52:47 +01:00
2025-02-27 10:01:12 +01:00
2025-02-27 10:01:12 +01:00
2025-03-27 15:12:55 +01:00
2025-03-27 15:12:55 +01:00
2025-03-11 15:24:22 +00:00
2025-03-11 15:24:22 +00:00
2025-03-13 20:39:54 +00:00
2025-03-13 20:39:54 +00:00
2025-03-24 22:08:19 +01:00
2025-03-24 22:08:19 +01:00
2025-03-25 22:36:54 +01:00
2025-03-25 22:36:54 +01:00
2025-03-25 19:53:48 +01:00
2025-03-25 19:53:48 +01:00
2025-03-27 08:43:42 +00:00
2025-03-27 08:43:42 +00:00
2025-03-20 09:54:55 +01:00
2025-03-20 09:54:55 +01:00
2025-03-22 18:37:48 +01:00
2025-03-22 18:37:48 +01:00
2025-03-27 09:47:34 +00:00
2025-03-27 09:47:34 +00:00
2025-04-10 20:39:01 +00:00
2025-04-10 20:39:01 +00:00
2025-04-10 20:39:01 +00:00
2025-04-10 20:39:01 +00:00
2025-03-25 02:00:51 +01:00
2025-03-25 02:00:51 +01:00
2025-03-26 18:38:47 +01:00
2025-03-26 18:38:47 +01:00
2025-04-07 14:58:08 +02:00
2025-04-07 14:58:08 +02:00
2025-04-09 09:38:48 +00:00
2025-04-09 09:38:48 +00:00
2025-04-12 14:47:48 +00:00
2025-04-12 14:47:48 +00:00
2025-05-09 09:50:01 +02:00
2025-05-09 09:50:01 +02:00
2025-04-17 21:51:18 +02:00
2025-04-17 21:51:18 +02:00
2025-04-23 12:18:36 +02:00
2025-04-23 12:18:36 +02:00
2025-04-21 14:43:15 +02:00
2025-04-21 14:43:15 +02:00
2025-05-05 08:54:48 +02:00
2025-05-05 08:54:48 +02:00
2025-04-28 19:17:24 +02:00
2025-04-28 19:17:24 +02:00
2025-04-29 23:32:30 +02:00
2025-04-29 23:32:30 +02:00
2025-04-29 23:47:48 +02:00
2025-04-29 23:47:48 +02:00
2025-05-09 09:50:01 +02:00
2025-05-09 09:50:01 +02:00
2025-05-06 17:59:21 +02:00
2025-05-06 17:59:21 +02:00
2025-05-15 17:38:45 +02:00
2025-05-15 17:38:45 +02:00
2025-05-27 15:52:57 +02:00
2025-05-27 15:52:57 +02:00
2025-05-15 17:54:49 +02:00
2025-05-15 17:54:49 +02:00
2025-05-15 21:59:30 +02:00
2025-05-15 21:59:30 +02:00
2025-05-21 17:49:21 +02:00
2025-05-21 17:49:21 +02:00
2025-05-26 19:38:01 +02:00
2025-05-26 19:38:01 +02:00
2025-06-05 09:30:23 +02:00
2025-06-05 09:30:23 +02:00
2025-07-03 21:02:45 +00:00
2025-07-03 21:02:45 +00:00
2025-06-17 19:49:00 +02:00
2025-06-17 19:49:00 +02:00
2025-06-20 12:07:33 +02:00
2025-06-20 12:07:33 +02:00
2025-07-11 09:56:53 +00:00
2025-07-11 09:56:53 +00:00
2025-07-15 01:50:22 +02:00
2025-07-15 01:50:22 +02:00
2025-07-11 18:55:23 +02:00
2025-07-11 18:55:23 +02:00
2025-07-14 13:08:28 +02:00
2025-07-14 13:08:28 +02:00
2025-07-17 22:15:01 +00:00
2025-07-17 22:15:01 +00:00
2025-07-21 20:08:56 +00:00
2025-07-21 20:08:56 +00:00
2025-08-06 13:55:36 +00:00
2025-07-19 11:04:28 +00:00
2025-07-19 23:16:35 +00:00
2025-07-19 23:16:35 +00:00
2025-08-15 13:03:32 +00:00
2025-08-15 13:03:32 +00:00
2025-08-07 16:46:53 +02:00
2025-08-07 16:46:53 +02:00
2025-08-06 13:55:36 +00:00
2025-08-06 13:55:36 +00:00
2025-07-28 08:52:39 +00:00
2025-07-28 08:52:39 +00:00
2025-08-06 13:55:36 +00:00
2025-08-06 13:55:36 +00:00
2025-08-06 22:40:42 +00:00
2025-08-06 22:40:42 +00:00
2025-08-07 17:45:50 +00:00
2025-08-07 17:45:50 +00:00
2025-08-14 09:06:00 +00:00
2025-08-14 09:06:00 +00:00
2025-08-14 09:06:00 +00:00
2025-08-14 09:06:00 +00:00
2025-08-20 22:40:57 +00:00
2025-08-20 22:40:57 +00:00
2025-09-10 17:42:45 +00:00
2025-09-10 17:42:45 +00:00
2025-08-27 17:44:35 +00:00
2025-08-27 17:44:35 +00:00
2025-08-28 16:56:57 +00:00
2025-08-28 16:56:57 +00:00
2025-08-31 12:19:59 +00:00
2025-08-31 12:19:59 +00:00
2025-09-02 07:48:03 +00:00
2025-09-02 07:48:03 +00:00
2025-09-02 20:15:37 +00:00
2025-09-02 20:15:37 +00:00
2025-09-05 16:06:51 +00:00
2025-09-05 16:06:51 +00:00
2025-09-08 17:27:58 +00:00
2025-09-08 17:27:58 +00:00
2025-09-09 21:04:23 +00:00
2025-09-09 21:04:23 +00:00
2025-09-05 16:06:51 +00:00
2025-09-05 16:06:51 +00:00
2025-09-09 21:04:23 +00:00
2025-09-09 21:04:23 +00:00
2025-09-17 16:48:37 +00:00
2025-09-17 16:48:37 +00:00
2025-09-23 19:22:54 +00:00
2025-09-23 19:22:54 +00:00
2025-09-26 11:26:50 +00:00
2025-09-26 11:26:50 +00:00
2025-10-03 14:04:21 +00:00
2025-10-03 14:04:21 +00:00
2025-10-16 16:49:35 +00:00
2025-10-16 16:49:35 +00:00
2025-10-08 09:18:15 +00:00
2025-10-08 09:18:15 +00:00
2025-10-03 16:30:06 +00:00
2025-10-03 16:30:06 +00:00
2025-10-08 09:18:15 +00:00
2025-10-08 09:18:15 +00:00
2025-10-03 17:27:58 +00:00
2025-10-03 17:27:58 +00:00
2025-10-17 03:42:41 +00:00
2025-10-17 03:42:41 +00:00
2025-10-07 07:00:00 +00:00
2025-10-07 07:00:00 +00:00
2025-10-09 05:07:18 +00:00
2025-10-09 05:07:18 +00:00
2025-10-15 22:30:09 +00:00
2025-10-15 22:30:09 +00:00
2025-10-17 14:05:17 +00:00
2025-10-17 14:05:17 +00:00
2025-10-23 20:18:08 +00:00
2025-10-23 20:18:08 +00:00
2025-10-17 13:55:02 +00:00
2025-10-17 13:59:58 +00:00
2025-10-24 15:24:46 +00:00
2025-10-24 15:24:46 +00:00
2025-10-27 15:49:43 +00:00
2025-10-27 15:49:43 +00:00
2025-10-30 16:24:44 +00:00
2025-10-30 16:24:44 +00:00
2025-10-28 10:17:47 +00:00
2025-10-28 10:17:47 +00:00
2025-11-17 08:51:35 +00:00
2025-11-17 08:51:35 +00:00
2025-12-15 18:01:07 +00:00
2025-12-15 18:01:07 +00:00
2025-10-30 16:21:08 +00:00
2025-10-30 16:21:08 +00:00
2025-11-07 15:27:00 +00:00
2025-11-07 15:27:00 +00:00
2025-11-12 15:32:07 +00:00
2025-11-12 15:32:07 +00:00
2025-11-28 16:00:11 +00:00
2025-11-28 16:00:11 +00:00
2025-11-18 23:04:31 +00:00
2025-11-18 23:04:31 +00:00
2025-12-12 22:52:26 +00:00
2025-12-12 22:52:26 +00:00
2025-12-12 22:52:26 +00:00
2025-11-17 22:26:47 +00:00
2025-11-18 23:03:35 +00:00
2025-11-18 23:03:35 +00:00
2025-12-05 23:08:58 +00:00
2025-12-05 23:08:58 +00:00
2025-12-05 23:08:58 +00:00
2025-12-05 23:08:58 +00:00
2025-12-08 16:20:49 +00:00
2025-12-08 16:20:49 +00:00
2025-12-08 16:20:49 +00:00
2025-12-08 16:20:49 +00:00
2025-11-29 11:28:51 +00:00
2025-11-29 11:28:51 +00:00
2025-12-08 16:42:35 +00:00
2025-12-08 16:42:35 +00:00
2025-12-04 09:50:07 +00:00
2025-12-04 09:50:07 +00:00
2025-12-16 21:17:06 +00:00
2025-12-16 21:17:06 +00:00
2025-12-05 18:01:27 +00:00
2025-12-05 18:01:27 +00:00
2025-12-08 16:35:39 +00:00
2025-12-08 16:35:39 +00:00
2025-12-16 21:16:42 +00:00
2025-12-16 21:16:42 +00:00
2025-12-23 13:24:04 +00:00
2025-12-23 13:24:04 +00:00
2025-12-18 16:17:33 +00:00
2025-12-18 16:17:33 +00:00
2025-12-19 19:46:46 +00:00
2025-12-19 19:46:46 +00:00
2026-01-05 20:52:48 +00:00
2026-01-05 20:52:48 +00:00
2025-12-19 20:07:23 +00:00
2025-12-19 20:07:23 +00:00
2026-01-08 06:25:59 +00:00
2026-01-08 06:25:59 +00:00
2026-01-09 14:57:15 +00:00
2026-01-09 14:57:15 +00:00
2026-01-20 13:38:02 +00:00
2026-01-20 13:38:02 +00:00
2026-01-26 16:49:52 +00:00
2026-01-26 16:49:52 +00:00
2026-01-14 12:06:40 +00:00
2026-01-14 12:06:40 +00:00
2026-02-10 16:49:25 +00:00
2026-02-10 16:49:25 +00:00
2026-01-17 13:24:58 +00:00
2026-01-17 13:24:58 +00:00
2026-01-20 19:19:21 +00:00
2026-01-20 19:19:21 +00:00
2026-01-20 21:54:01 +01:00
2026-01-20 21:54:01 +01:00
2026-01-24 19:26:06 +00:00
2026-01-24 19:26:06 +00:00
2026-01-25 22:32:21 +00:00
2026-01-25 22:32:21 +00:00
2026-01-27 00:01:35 +00:00
2026-01-27 00:01:35 +00:00
2026-02-02 10:09:40 +00:00
2026-02-02 10:09:40 +00:00
2026-02-02 10:09:40 +00:00
2026-02-02 10:09:40 +00:00
2026-01-29 17:32:48 +00:00
2026-01-29 17:32:48 +00:00
2026-01-29 22:31:49 +00:00
2026-01-29 22:31:49 +00:00
2026-02-04 15:30:54 +00:00
2026-02-04 15:30:54 +00:00
2026-02-04 16:27:53 +00:00
2026-02-04 16:27:53 +00:00
2026-02-04 07:35:29 +00:00
2026-02-04 07:35:29 +00:00
2026-02-04 17:53:55 +00:00
2026-02-04 17:53:55 +00:00
2026-02-04 18:48:51 +00:00
2026-02-04 18:48:51 +00:00
2026-02-10 09:50:24 +00:00
2026-02-10 09:50:24 +00:00
2026-02-05 19:39:45 +00:00
2026-02-05 19:39:45 +00:00
2026-02-05 23:46:47 +00:00
2026-02-05 23:46:47 +00:00
2026-02-06 06:18:38 +00:00
2026-02-06 06:18:38 +00:00
2026-02-16 15:52:02 +00:00
2026-02-16 15:52:02 +00:00
2026-02-06 07:41:25 +00:00
2026-02-06 08:14:21 +00:00
2026-02-06 07:41:25 +00:00
2026-02-06 08:14:21 +00:00
2026-02-06 07:41:25 +00:00
2026-02-06 08:14:21 +00:00
2026-02-06 07:41:25 +00:00
2026-02-06 08:14:21 +00:00
2026-02-12 23:02:36 +00:00
2026-02-12 23:02:36 +00:00
2026-02-12 23:02:05 +00:00
2026-02-12 23:02:05 +00:00
2026-02-16 15:52:02 +00:00
2026-02-16 15:52:02 +00:00
2026-02-16 23:36:41 +00:00
2026-02-16 23:36:41 +00:00
2026-02-23 17:50:37 +00:00
2026-02-23 17:50:37 +00:00
2026-02-25 12:05:22 +00:00
2026-02-25 12:05:22 +00:00
2026-02-25 15:06:12 +00:00
2026-02-25 15:06:12 +00:00
2026-02-26 00:39:15 +01:00
2026-02-26 00:01:17 +00:00
2026-03-05 06:19:51 +00:00
2026-03-05 06:19:51 +00:00
2026-02-28 18:18:34 +00:00
2026-02-28 18:18:34 +00:00
2026-03-05 05:22:46 +00:00
2026-03-05 05:22:46 +00:00
2026-03-10 12:58:00 +00:00
2026-03-10 12:58:00 +00:00
2026-03-10 04:59:56 +00:00
2026-03-10 04:59:56 +00:00
2026-03-11 00:10:29 +00:00
2026-03-11 00:10:29 +00:00
2026-03-12 14:00:30 +00:00
2026-03-12 14:00:30 +00:00