Guia do Desenvolvedor para o Serviço Streaming
Use SDKs do OCI para interagir com o Streaming sem criar uma estrutura.
Os SDKs do OCI permitem que você gerencie gerencie streams, gerencie pools de streams e gerencie configurações do Kafka Connect, e publice e consuma mensagens. Consulte a Visão Geral do Streaming para obter conceitos-chave e mais informações.
Esta seção inclui os seguintes tópicos para ajudá-lo a começar a usar rapidamente o serviço Streaming e o SDK do OCI de sua escolha:
- SDK para Início Rápido de Streaming do Java
- SDK para Início Rápido de Streaming do Python
- SDK para Início Rápido de Streaming do JavaScript
- SDK para Início Rápido de Streaming do TypeScript
- SDK para Início Rápido do Streaming do .NET
- SDK para Início Rápido de Streaming do Go
Para obter mais informações sobre como usar os SDKs do OCI, consulte os Guias do SDK.
Como o Oracle Cloud Infrastructure Streaming é compatível com a maioria das APIs Kafka, você pode usar aplicativos criados para Kafka para enviar mensagens e receber mensagens do serviço Streaming. Consulte Desenvolvendo com o Kafka e o Streaming para obter mais informações.
Clientes do Streaming
Os SDKs encapsulam o serviço Streaming em dois clientes: o StreamAdminClient e o StreamClient.
StreamAdminClient
O StreamAdminClient incorpora as operações do plano de controle do serviço Streaming. Você pode usá-lo para criar, excluir, atualizar, modificar e listar streams.
Para instanciar o objeto StreamAdminClient:
StreamAdminClient adminClient = new StreamAdminClient([authProvider]);
adminClient.setEndpoint("<streaming_endpoint>");StreamClient
O StreamClient é usado para publicar e consumir mensagens.
Para instanciar um 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());