OCI Stream - Pull messages from OCI stream - based on Certain Condition

Summary:

Need your expert advice on the following requirement.

We have a scenario where one OIC integration publishes data to an OCI Stream. A subscriber integration, running every one minute, consumes messages from the stream (for example, in batches of 50, assuming this is configurable).

Before the subscriber attempts to consume the next batch of 50 messages, we want it to first verify whether the previously consumed messages have completed processing. If they are not completed, the subscriber should not pull the next batch.

For example, the publisher integration pushes messages to the OCI Stream in the following format:

{ "ReprocessID": "123", "Status": "Queue"}