stop
Stops reading, waits at most SubscriptionOptions.stopTimeout for the entries in flight, abandons the rest, and saves every checkpoint. An abandoned entry is above the saved checkpoint and is handled after a restart.
Stops reading, waits at most SubscriptionOptions.stopTimeout for the entries in flight, abandons the rest, and saves every checkpoint. An abandoned entry is above the saved checkpoint and is handled after a restart.