chore: watermark refactor #3270

Job	Run time
Lint	4m 29s
Lint	4m 29s
E2E Tests (jetstream, e2e)	15m 20s
E2E Tests (jetstream, e2e)	15m 20s
E2E Tests (jetstream, diamond-e2e)	12m 7s
E2E Tests (jetstream, diamond-e2e)	12m 7s
E2E Tests (jetstream, transformer-e2e)	11m 52s
E2E Tests (jetstream, transformer-e2e)	11m 52s
E2E Tests (jetstream, kafka-e2e)	10m 8s
E2E Tests (jetstream, kafka-e2e)	10m 8s
E2E Tests (jetstream, http-e2e)	8m 7s
E2E Tests (jetstream, http-e2e)	8m 7s
E2E Tests (jetstream, nats-e2e)	7m 55s
E2E Tests (jetstream, nats-e2e)	7m 55s
E2E Tests (jetstream, redis-streams-e2e)	2m 32s
E2E Tests (jetstream, redis-streams-e2e)	10m 2s
E2E Tests (jetstream, sdks-e2e)	15m 19s
E2E Tests (jetstream, sdks-e2e)	15m 19s
E2E Tests (jetstream, reduce-e2e)	18m 59s
E2E Tests (jetstream, reduce-e2e)	18m 59s
E2E Tests (jetstream, udsource-e2e)	6m 58s
E2E Tests (jetstream, udsource-e2e)	6m 58s
Codegen	2m 19s
Codegen	2m 19s
UI	1m 52s
UI	1m 52s
Unit Tests	5m 46s
Unit Tests	5m 46s
	4h 14m 56s

Provide feedback