Documentation sur Oracle Cloud Infrastructure

Guide du développeur pour le service de diffusion en continu

Utilisez les trousses SDK OCI pour interagir avec le service de diffusion en continu sans créer de cadre.

Les trousses SDK pour OCI vous permettent de gérer les flux, de gérer les groupes de flux et de gérer les configurations Kafka Connect, et de publier et de consommer les messages. Voir Aperçu du service de diffusion en continu pour plus d'informations sur les concepts clés.

Cette section présente les rubriques suivantes pour vous aider à démarrer rapidement avec le service de diffusion en continu et la trousse SDK pour OCI de votre choix :

Pour plus d'informations sur l'utilisation des trousses SDK pour OCI, consultez les guides sur les trousses SDK.

Comme le service Oracle Cloud Infrastructure Streaming est compatible avec la plupart des API Kafka, vous pouvez utiliser des applications écrites pour Kafka pour envoyer des messages vers et recevoir des messages du service de diffusion en continu. Pour plus d'informations, voir Développement avec Kafka et le service de diffusion en continu.

Clients du service de diffusion en continu

Les trousses SDK encapsulent le service de diffusion en continu dans deux clients : StreamAdminClient et StreamClient.

StreamAdminClient

StreamAdminClient intègre les opérations du plan de contrôle du service de diffusion en continu. Vous pouvez l'utiliser pour créer, supprimer, mettre à jour, modifier et répertorier des flux.

Pour instancier l'objet StreamAdminClient  :

StreamAdminClient adminClient = new StreamAdminClient([authProvider]);
adminClient.setEndpoint("<streaming_endpoint>");

StreamClient

Le client StreamClient est utilisé pour publier et consommer des messages.

Pour instancier un objet StreamClient  :

// 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());