Consumindo Mensagens

Usando um cursor especificado, consuma mensagens de um stream no serviço Streaming.

O consumo de mensagens de um stream exige que você:

  • Crie um cursor.
  • Use o cursor para obter ou ler mensagens.
  • Use o cursor retornado para continuar lendo mensagens.

Você pode usar um consumidor individual para ler mensagens de um ou mais streams ou usar grupos de consumidores para ler mensagens de um stream.

Veja a seguir as tarefas que você pode fazer relacionadas ao consumo de mensagens.

Dica

Você também pode usar o Oracle Cloud Infrastructure Connector Hub para consumir dados de um stream e transmitir mensagens para o serviço Object Storage ou qualquer outro destino suportado do Connector Hub.

Você pode mostrar as mensagens mais recentes em um stream usando a Console. No entanto, para consumir mensagens do stream, use a CLI, a API ou um SDK para criar e usar cursores.

Para consumir mensagens usando SDKs do OCI, consulte o Developer Guide to Streaming. Consulte também Desenvolvendo com o Kafka e o Serviço Streaming.

Política do Serviço IAM Obrigatória

Para usar o Oracle Cloud Infrastructure, um administrador deve ser membro de um grupo com acesso de segurança concedido em uma política por um administrador da tenancy. Esse acesso será necessário se você estiver usando a Console ou a API REST com um SDK, uma CLI ou outra ferramenta. Se você receber uma mensagem de que não tem permissão ou que não está autorizado, verifique com o administrador da tenancy qual tipo de acesso você tem e em qual compartimento seu acesso funciona.

Para administradores: A política em Permitir que administradores do streaming gerenciem recursos do streaming permite que o grupo especificado faça tudo com o streaming e os recursos relacionados ao serviço Streaming.

Você pode criar uma política que dê acesso stream-pull a um tenant para consumir dados de um fluxo em outro tenant. Para obter mais informações sobre políticas de Streaming, consulte Acessando Recursos de Streaming entre Tenancies e Detalhes do Serviço Streaming.

Se você for iniciante em políticas, consulte Visão Geral de Políticas do Serviço IAM.