Entwicklerdokumentation für Streaming
Verwenden Sie OCI-SDKs, um mit Streaming zu interagieren, ohne ein Framework zu erstellen.
Mit den OCI-SDKs können Sie Streams verwalten, Streampools verwalten und Kafka Connect-Konfigurationen verwalten sowie Nachrichten veröffentlichen und konsumieren. Wichtige Konzepte und weitere Informationen finden Sie im Streaming - Überblick.
Dieser Abschnitt enthält die folgenden Themen, die Ihnen den schnellen Einstieg in Streaming und das OCI-SDK Ihrer Wahl erleichtern:
- SDK für Java mit Streaming verwenden - Schnellstart
- SDK für Python mit Streaming verwenden - Schnellstart
- SDK für JavaScript mit Streaming verwenden - Schnellstart
- SDK für TypeScript mit Streaming verwenden - Schnellstart
- SDK für .NET mit Streaming verwenden - Schnellstart
- SDK für Go mit Streaming verwenden - Schnellstart
Weitere Informationen zur Verwendung der OCI-SDKs finden Sie in den SDK-Dokumentationen.
Da Oracle Cloud Infrastructure Streaming mit den meisten Kafka-APIs kompatibel ist, können Sie für Kafka geschriebene Anwendungen verwenden, um Nachrichten an den Streaming-Service zu senden und von ihm zu empfangen. Weitere Informationen finden Sie unter Mit Kafka und Streaming entwickeln.
Streaming-Clients
Die SDKs verkapseln den Streaming-Service in zwei Clients: StreamAdminClient und StreamClient.
StreamAdminClient
Der StreamAdminClient deckt die Vorgänge der Control Plane von Streaming ab. Mit ihm können Sie Streams erstellen, löschen, aktualisieren, ändern und auflisten.
So instanziieren Sie das StreamAdminClient -Objekt:
StreamAdminClient adminClient = new StreamAdminClient([authProvider]);
adminClient.setEndpoint("<streaming_endpoint>");StreamClient
Mit StreamClient werden Nachrichten veröffentlicht und konsumiert.
So instanziieren Sie ein StreamClient -Objekt:
// 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());