Hitorro Streams Nats

NATS JetStream source (Iterator<JVS>) and sink (Sink<JsonNode>) for the hitorro-streams pipeline framework and hitorro-jvssql. Uses jnats pull subscriptions with durable consumers so restarts resume from the last acked message.