Hanzo Dev 5e3f4d808e Fix event pipeline and add admin HTTP endpoint ...

- Fix NATS JetStream subject mismatch: SubjectName now returns
  StreamName + ".data" to match existing stream subjects, fixing
  capture produce failures ("Unknown broker error")
- Fix OffsetFetch flexible version threshold (v6, not v8) and add
  version-aware encoding for v0-v5 (non-flexible) vs v6-v7 (flexible)
- Fix ApiVersions to use non-flexible encoding for v0-v2
- Add offset out-of-range detection in Fetch with proper error code
- Add offset validation and corruption purge in consumer offsets
- Add admin HTTP server on :9093 with /status, /topics, /groups
  endpoints for Kafka-friendly monitoring without raw NATS access
- Reduce Fetch/Heartbeat/ListOffsets request logging to DEBUG
- Set default log level to INFO
- Log RecordBatch hex on Produce for debugging

2026-02-23 16:24:18 -08:00

..

config.go

Fix event pipeline and add admin HTTP endpoint

2026-02-23 16:24:18 -08:00

log.go

rebrand to Hanzo Kafka: thin Kafka wire protocol gateway over Hanzo PubSub

2026-02-22 13:38:22 -08:00

request.go

added some error messages

2025-03-01 11:22:27 -06:00