Guide du développeur pour Streaming
Utilisez les kits SDK OCI pour interagir avec Streaming sans créer de structure.
The OCI SDKs let you manage manage streams, manage stream pools, and manage Kafka Connect configurations, and publish and consume messages. Pour connaître les concepts clés et plus d'informations, reportez-vous à Présentation de Streaming.
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 majorité des API Kafka, vous pouvez utiliser les 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());