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 Kafka Connect e i messaggi di pubblicazione e consumo. Per ulteriori informazioni e concetti chiave, vedere la Panoramica dello streaming.
Questa sezione include i seguenti argomenti per iniziare rapidamente a utilizzare lo streaming e l'SDK OCI di tua scelta:
- SDK per Quickstart Streaming Java
- SDK per Quickstart streaming Python
- SDK per Quickstart Streaming JavaScript
- SDK per Quickstart Streaming TypeScript
- SDK per Quickstart Streaming .NET
- SDK per Quickstart 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 messaggi e ricevere messaggi dal servizio di streaming. Per ulteriori informazioni, vedere 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());