Developer Guide to Streaming
Oracle Cloud Infrastructure (OCI) provides SDKs so that you can interact with Streaming without having to create a framework.
The OCI SDKs let you manage streams and stream pools and Kafka Connect configurations, and publish and consume messages. Refer to the Overview of Streaming for key concepts and additional information.
This section includes the following topics to help you get started quickly with Streaming and the OCI SDK of your choice:
- SDK for Java Streaming Quickstart
- SDK for Python Streaming Quickstart
- SDK for TypeScript Streaming Quickstart
- SDK for .NET Streaming Quickstart
- SDK for Go Streaming Quickstart
For more information about using the OCI SDKs, see the SDK Guides.
Because Oracle Cloud Infrastructure Streaming is compatible with most Kafka APIs, you can use applications written for Kafka to send messages to and receive messages from the Streaming service. See Developing with Kafka and Streaming for more information.
The SDKs encapsulate the Streaming service in two
StreamAdminClient and the
StreamAdminClient incorporates the control plane operations of
Streaming. You can use it to create, delete,
update, modify, and list streams.
To instantiate the
StreamAdminClient adminClient = new StreamAdminClient([authProvider]); adminClient.setEndpoint("<streaming_endpoint>");
StreamClient is used to publish and consume messages.
To instantiate a
// First you have to get the stream you want to consume from/publish to. // You can either make a CreateStream, GetStream, or ListStream call. They all return a "messagesEndpoint" as part of a Stream object. // That endpoint needs to be used when creating the StreamClient object. GetStreamRequest getStreamRequest = GetStreamRequest.builder().streamId(streamId).build(); Stream stream = adminClient.getStream(getStreamRequest).getStream(); StreamClient streamClient = new StreamClient([authProvider]); streamClient.setEndpoint(stream.getMessagesEndpoint());