Module source

Expand description

NATS source: JetStream pull consumer with bounded asynchronous acknowledgement, or core subscribe (at-most-once). Messages are acknowledged only after successful deserialization; the source remains explicitly ephemeral and does not couple broker acks to checkpoints.