fn keyBytes

data OrderEvent {
  userId: u64
  seq: i64
}

topic OrderEvents: OrderEvent sharded by .userId

cluster demo {
  role store { journal }
}

fn main() -> () | TopicError io, db {
  OrderEvents.publish(OrderEvent{ userId: 7, seq: 0 })?
  OrderEvents.publish(OrderEvent{ userId: 7, seq: 1 })?
  var seen = ""
  for await e in OrderEvents.subscribeKey(7 as u64, from: .Earliest) {
    seen = "{seen}{e.seq},"
    if e.seq == 1 { break }
  }
  print(seen)
}

0,1,