Guide du développeur pour Streaming
Utilisez les kits SDK OCI pour interagir avec Streaming sans créer de structure.
Les kits SDK OCI vous permettent de gérer des flux de données, de gérer des pools de flux de données et de gérer des configurations Kafka Connect, ainsi que de publier et d'utiliser des messages. Reportez-vous à Présentation de Streaming pour connaître les concepts clés et obtenir plus d'informations.
Cette section comprend les rubriques suivantes qui vous aident à démarrer rapidement avec Streaming et le kit SDK OCI de votre choix :
- Démarrage rapide du kit SDK pour Java avec Streaming
- Démarrage rapide du kit SDK pour Python avec Streaming
- Démarrage rapide du kit SDK pour JavaScript avec Streaming
- Démarrage rapide du kit SDK pour TypeScript avec Streaming
- Démarrage rapide du kit SDK pour .NET avec Streaming
- Démarrage rapide du kit SDK pour Go avec Streaming
Pour plus d'informations sur l'utilisation des kits SDK OCI, reportez-vous aux guides de kit SDK.
Oracle Cloud Infrastructure Streaming étant compatible avec la plupart des API Kafka, vous pouvez utiliser des applications écrites pour Kafka afin d'envoyer des messages vers le service Streaming et d'en recevoir. Pour plus d'informations, reportez-vous à Développement avec Kafka et Streaming.
Clients Streaming
Les kits SDK encapsulent le service Streaming dans deux clients : StreamAdminClient et StreamClient.
StreamAdminClient
StreamAdminClient incorpore les opérations de plan de contrôle de Streaming. Vous pouvez l'utiliser pour créer, supprimer, mettre à jour, modifier et répertorier des flux.
Procédure d'instanciation de l'objet StreamAdminClient :
StreamAdminClient adminClient = new StreamAdminClient([authProvider]);
adminClient.setEndpoint("<streaming_endpoint>");StreamClient
StreamClient permet de publier et d'utiliser des messages.
Procédure d'instanciation d'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());