Guida per gli sviluppatori allo streaming
Utilizza gli SDK OCI per interagire con lo streaming senza creare un framework.
Gli SDK OCI consentono di gestire i flussi di gestione, i pool di flussi di gestione e le configurazioni di Kafka Connect, nonché di pubblicare e consumare i messaggi. Per concetti chiave e ulteriori informazioni, vedere Panoramica sullo streaming.
Questa sezione include i seguenti argomenti per iniziare rapidamente a utilizzare lo streaming e l'SDK OCI di tua scelta:
- Avvio rapido SDK per Java Streaming
- Avvio rapido SDK per lo streaming Python
- SDK per JavaScript Avvio rapido dello streaming
- SDK per TypeScript Avvio rapido dello streaming
- Avvio rapido SDK per lo streaming .NET
- Avvio rapido SDK per Go Streaming
Per ulteriori informazioni sull'uso degli SDK OCI, consulta le guide SDK.
Poiché Oracle Cloud Infrastructure Streaming è compatibile con la maggior parte delle API Kafka, puoi utilizzare le applicazioni scritte per Kafka per inviare e ricevere messaggi dal servizio di streaming. Per ulteriori informazioni, consulta la sezione Sviluppo con Kafka e streaming.
client in streaming
Gli SDK incapsulano il servizio di streaming in due client: StreamAdminClient e StreamClient.
StreamAdminClient
StreamAdminClient incorpora le operazioni del piano di controllo dello streaming. È possibile utilizzarlo per creare, eliminare, aggiornare, modificare ed elencare i flussi.
Per creare un'istanza dell'oggetto StreamAdminClient:
StreamAdminClient adminClient = new StreamAdminClient([authProvider]);
adminClient.setEndpoint("<streaming_endpoint>");StreamClient
StreamClient viene utilizzato per pubblicare e utilizzare i messaggi.
Per creare un'istanza di un oggetto 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());