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 de gestión, gestionar pools de flujos, gestionar configuraciones de Kafka Connect, y mensajes de publicación y consumo. Consulte Descripción general de Streaming para obtener más información y conceptos clave.
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 la mayoría de las API de Kafka, puede utilizar aplicaciones escritas para Kafka para 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());