fn noKey

data Job { id: i64 }

topic Jobs: Job

cluster demo {
  role store { journal }
}

fn main() -> () | TopicError io, db {
  Jobs.publish(Job{ id: 5 })?
  for await j in Jobs.subscribe(from: .Earliest) {
    print("job {j.id}")
    break
  }
}

job 5