Guía para desarrolladores de Streaming
Utilice los SDK de OCI para interactuar con Streaming sin crear un marco.
Los SDK de OCI le permiten gestionar flujos, gestionar pools de flujos y gestionar configuraciones de Kafka Connect, así como mensajes de publicación y consumo. Consulte la Visión general de Streaming para ver los conceptos clave y más información.
Esta sección incluye los siguientes temas para ayudarle a comenzar rápidamente con Streaming y el SDK de OCI de su elección:
- SDK de inicio rápido de Streaming para Java
- SDK de inicio rápido de Streaming para Python
- SDK de inicio rápido de Streaming para JavaScript
- SDK de inicio rápido de Streaming para TypeScript
- SDK de inicio rápido de Streaming para .NET
- SDK de inicio rápido de Streaming para Go
Para obtener más información sobre el uso de los SDK de OCI, consulte las Guías sobre SDK.
Dado que Oracle Cloud Infrastructure Streaming es compatible con los API de Kafka, puede utilizar aplicaciones escritas para Kafka a fin de enviar mensajes al servicio Streaming y recibirlos. Consulte Desarrollo con Kafka y Streaming para obtener más información.
Clientes de Flujo
Los SDK encapsulan el servicio Streaming en dos clientes: StreamAdminClient y StreamClient.
StreamAdminClient
StreamAdminClient incorpora las operaciones de plano de control de Streaming. Puede utilizarlo para crear, suprimir, actualizar, modificar y mostrar flujos.
Para instanciar el objeto StreamAdminClient :
StreamAdminClient adminClient = new StreamAdminClient([authProvider]);
adminClient.setEndpoint("<streaming_endpoint>");StreamClient
Se utiliza StreamClient para publicar y consumir mensajes.
Para instanciar un objeto 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());