feat(consumoor): add snapshot/fuzz tests, fix Slot double-append bug, staging test infra

Add comprehensive test suite for all 77 flattener routes:

- TestSnapshotCorrectness: synthetic proto events with exact column value
  assertions for every route, completeness enforcement requiring non-empty
  checks for each fixture
- FuzzFlattenColumnAlignment: random proto bytes verify no panics and
  column alignment across all routes
- FuzzFlattenNilSafety: partially-constructed events verify nil-safety
- Extended TestConditionalRoutingPredicates to cover all 5 predicate routes
- Extended TestValidatorsFanout to cover all 3 fan-out routes

Fix canonical_beacon_block Slot column double-append: both appendPayload
and appendAdditionalData were appending to b.Slot when additional data
had Slot.Number set, breaking column alignment.

Refactor staging correctness test infrastructure: replace smoke-test script
with staging-correctness-test.sh and staging-topic-survey.sh, add docker
compose staging overlay.

Author: samcm

.gitignore

@@ -18,3 +18,4 @@ sage.yaml
 relay-monitor.yaml
 cities1000.txt
 countries.txt
+deploy/local/docker-compose/xatu-consumoor-staging.yaml

deploy/local/docker-compose/docker-compose.staging.yml

@@ -0,0 +1,54 @@
+# Staging overlay: disables local Kafka, Vector, and non-essential services.
+# Consumoor connects to staging Kafka via host.docker.internal (port-forwarded).
+#
+# Usage:
+#   docker compose -f docker-compose.yml -f deploy/local/docker-compose/docker-compose.staging.yml up -d
+#
+# See deploy/local/docker-compose/staging-correctness-test.sh for the full workflow.
+
+services:
+  # --- Disabled services (not needed for staging correctness test) ---
+  xatu-kafka:
+    profiles: ["disabled"]
+  xatu-kafka-storage-format:
+    profiles: ["disabled"]
+  xatu-init-kafka:
+    profiles: ["disabled"]
+  xatu-server:
+    profiles: ["disabled"]
+  xatu-postgres:
+    profiles: ["disabled"]
+  xatu-postgres-migrator:
+    profiles: ["disabled"]
+  xatu-vector-http-kafka:
+    profiles: ["disabled"]
+  xatu-vector-kafka-clickhouse:
+    profiles: ["disabled"]
+  xatu-vector-kafka-clickhouse-libp2p:
+    profiles: ["disabled"]
+  xatu-sentry-logs:
+    profiles: ["disabled"]
+  xatu-cannon:
+    profiles: ["disabled"]
+  xatu-nginx:
+    profiles: ["disabled"]
+  xatu-grafana:
+    profiles: ["disabled"]
+  xatu-prometheus:
+    profiles: ["disabled"]
+  tempo:
+    profiles: ["disabled"]
+  tempo-init:
+    profiles: ["disabled"]
+
+  # --- Override consumoor to use staging Kafka ---
+  xatu-consumoor:
+    volumes:
+      - ./deploy/local/docker-compose/xatu-consumoor-staging.yaml:/etc/consumoor/config.yaml
+    extra_hosts:
+      - "host.docker.internal:host-gateway"
+    depends_on:
+      xatu-clickhouse-01:
+        condition: service_healthy
+      xatu-clickhouse-consumoor-init:
+        condition: service_completed_successfully