
offset The location of a message within a partition. key An identifier used to group related messages. Interaction lack of interaction results in a timeout, removing the instanceįrom the consumer group. Specific partition can only be consumed by a single consumer in the group. Messages from all partitions in a stream. consumer group A set of instances which coordinate to consume consumer An entity that reads messages from one or more streams. producer An entity that publishes messages to a stream. Producers and consumers should agree upon the message format. Streaming is schema-agnostic and acceptsĪny message format, including XML, JSON, CSV, and even compressed formats suchĪs gzip. message A Base64-encoded message that is published to a Specific offset or time in a partition, or to a group's current cursorĪ pointer to a location in a stream. This alsoĪllows multiple consumers to read from a stream in parallel. Partitions allow you toĭistribute a stream by splitting messages across multiple nodes. stream poolĪ grouping that you can use to organize and manage streams, including any stream A partitioned, append-only log of messages. The following concepts are essential to understanding and working with Streaming. Messages to and receive messages from the Streaming service without having to rewriteĪdvantage of the Kafka Connect ecosystem to interface directly withįirst-party and third-party products by using out-of-the-box Kafka sourceĪnd sink connectors. Setup, maintenance, and management of the infrastructure that hosting your ownĪPIs, allowing you to use applications written for Kafka to send Kafka compatibility Streaming makes it possible to offload the Maintaining Streaming's order guarantees. Stream's messages, and output the transformed messages to Object Storage or any other supported You can designate a stream as a data source, use Oracle Cloud Infrastructure Functions to transform the Stream processing Streaming's integration with Oracle Cloud Infrastructure Service Connector Hub means that Network (VCN) within your tenancy so that its streams cannot be accessedįor more information, see Securing a Stream. Private endpoints restrict access to a specified virtual cloud Integration with Oracle Cloud Infrastructure Identity and Access Management (IAM) lets youĬontrol who and what services can access which keys and what they can do Specific compliance or security standards. Securely store and manage your own encryption keys if you need to meet You can let Oracle manage encryption, or use the Oracle Cloud Infrastructure Vault service to Streaming data is encrypted both at rest and in transit, ensuring message Refer to the Oracle Cloud Infrastructure Service Level Service-level agreement (SLA) for Streaming. This ensures that even the failure of anĪvailability domain or fault domain does not result in data loss. In regions with a single availability domain, the data is replicatedĪcross multiple fault domains. Synchronously replicated across three availability domains whenĪvailable. Durability and Availability Messages published to the Streaming service are Integration with Monitoring andĬonsumer groups can handle your message offsets. Infrastructure to its provisioning, deployment, maintenance, security patching,Īnd replication. Streaming provides the following features: Fully managed Streaming is fully managed, from the underlying Infrastructure and apps event processing Use Streaming as a unified entry point for cloud components to report their lifecycle events for audit, accounting, and related activities.
Streamcloud to Offline#
You can use this information for real-time monitoring and analytics, and in data warehousing systems for offline processing and reporting. Web or mobile activity data ingestion Use Streaming for capturing activity from websites or mobile apps, such as page views, searches, or other user actions. Metric and log ingestion Use Streaming as an alternative for traditional file-scraping approaches to help make critical operational data more quickly available for indexing, analysis, and visualization. Producers and consumers can use Streaming as an asynchronous message bus and act independently and at their own pace. You can use Streaming for: Messaging Use Streaming to decouple the components of large systems. Use Streaming for any use case in which data is produced and processed continually and sequentially in a publish-subscribe messaging model. The Oracle Cloud Infrastructure Streaming service provides a fully managed, scalable, and durable solution for ingesting and consuming high-volume data streams in real-time.
