Streaming actions

Every Streaming action

• OCI Streaming: Commit Consumer OffsetsCommit a consumer group's cursor offsets so a later reader resumes where the group left off instead of replaying. Supply the stream OCID and the group cursor (from Create Group Cursor); the committed cursor is returned to reuse. The stream's endpoint is resolved automatically.
• OCI Streaming: Consume MessagesRead a batch of messages from a stream using a cursor (from Create Cursor or Create Group Cursor). Returns the messages plus a next cursor to feed into the following call to page forward. The stream's endpoint is resolved automatically.
• OCI Streaming: Create Connect HarnessCreate a connect harness for Kafka Connect support. Give it a name and a compartment. Returns the harness in a CREATING state: poll Get Connect Harness until ACTIVE.
• OCI Streaming: Create CursorCreate a partition cursor marking where a consumer starts reading: the oldest retained message (TRIM_HORIZON), only new messages (LATEST), a specific offset (AT_OFFSET / AFTER_OFFSET) or a point in time (AT_TIME). Pass the returned cursor into Consume Messages.
• OCI Streaming: Create Group CursorCreate a consumer-group cursor for a stream. Give it a group name and a starting position (LATEST, TRIM_HORIZON, or AT_TIME with a timestamp); the group shares the stream's partitions and tracks its own committed position. Returns a cursor to feed into Consume Messages. The stream's endpoint is resolved automatically.
• OCI Streaming: Create StreamCreate a Kafka-compatible stream. Give it a name and a partition count, and either a compartment (uses that compartment's default stream pool) or a specific stream pool. Returns the stream in a CREATING state: poll Get Stream until ACTIVE.
• OCI Streaming: Create Stream PoolCreate a stream pool in a compartment to hold your streams. Give it a name and optional tags; Kafka settings, private endpoint and encryption are left at their defaults. Returns the pool in a CREATING state: poll Get Stream Pool until ACTIVE.
• OCI Streaming: Delete Connect HarnessDelete a connect harness by OCID. Asynchronous: returns a work request OCID you can poll with Get Work Request to confirm removal.
• OCI Streaming: Delete StreamDelete a stream by OCID. The stream moves to a DELETING state and its messages are discarded: this cannot be undone. Returns a work request OCID to track the asynchronous removal.
• OCI Streaming: Delete Stream PoolDelete a stream pool by OCID. Asynchronous: the pool moves to DELETING and a work request OCID is returned to track the teardown.
• OCI Streaming: Get Connect HarnessRead a connect harness by OCID: its lifecycle state, name and compartment.
• OCI Streaming: Get Consumer GroupRead the current state of a consumer group on a stream: its partition reservations, the instance holding each partition, and the latest committed offset. The stream's endpoint is resolved automatically.
• OCI Streaming: Get StreamRead a stream by OCID: its lifecycle state, partitions, retention and messages endpoint.
• OCI Streaming: Get Stream PoolRead a stream pool by OCID: its lifecycle state, compartment, privacy and endpoint FQDN.
• OCI Streaming: Get Work RequestRead a Streaming work request by OCID: its operation type, status and percent-complete, to track a long-running create, update, delete or move.
• OCI Streaming: Heartbeat ConsumerHeartbeat a group cursor to keep this consumer's partition lease alive so the group does not rebalance away from it. Returns a refreshed cursor to use on the next heartbeat or consume call. The stream's endpoint is resolved automatically.
• OCI Streaming: List Connect HarnessesList the connect harnesses in a compartment, optionally filtered by OCID, exact name or lifecycle state. Walks pagination up to a safe cap.
• OCI Streaming: List Stream PoolsList the stream pools in a compartment, optionally filtered by OCID, exact name, or lifecycle state. Walks pagination up to a safe cap.
• OCI Streaming: List StreamsList the streams in a compartment, optionally narrowed to a stream pool or filtered by name, OCID or lifecycle state. Walks pagination up to a safe cap.
• OCI Streaming: List Work Request ErrorsList the errors recorded against a Streaming work request: each error's code, message and timestamp.
• OCI Streaming: List Work Request LogsList the log entries for a Streaming work request: the progress messages recorded as an asynchronous stream, stream pool or connect harness operation runs. Walks pagination up to a safe cap.
• OCI Streaming: List Work RequestsList the asynchronous work requests in a compartment: each tracks a long-running Streaming operation with its operation type, status and percent complete. Walks pagination up to a safe cap.
• OCI Streaming: Move Connect Harness to CompartmentMove a connect harness into a different compartment. Supply the connect harness OCID and the destination compartment OCID. The move is asynchronous and returns a work request OCID to poll.
• OCI Streaming: Move Stream PoolMove a stream pool into a different compartment. Give it the stream pool OCID and the destination compartment OCID. Asynchronous: returns a work request OCID you can poll.
• OCI Streaming: Move Stream to CompartmentMove a stream into a different compartment. Supply the stream OCID and the destination compartment OCID. The move is asynchronous and returns a work request OCID to poll.
• OCI Streaming: Publish MessagePublish a message to a stream. Supply the stream OCID and a value; an optional key pins related messages to the same partition to preserve their order. The stream's endpoint is resolved automatically.
• OCI Streaming: Reset Consumer GroupForcefully move a consumer group to a new position in a stream, resetting every consumer at once: to the latest messages, the oldest retained message, or a specific time. The stream's endpoint is resolved automatically.
• OCI Streaming: Update Connect HarnessUpdate a connect harness by OCID: change its freeform and defined tags. Only the fields you supply are changed. Returns the harness in an UPDATING state along with a work request OCID.
• OCI Streaming: Update StreamUpdate a stream in place. Move it to a different stream pool and/or replace its freeform or defined tags: only the fields you provide are changed. Returns the stream in an UPDATING state; poll Get Stream until ACTIVE.
• OCI Streaming: Update Stream PoolUpdate a stream pool by OCID: change its name and/or its freeform and defined tags. Only the fields you supply are changed. Returns the pool in an UPDATING state along with a work request OCID.

Also in Oracle Cloud