Messaggi di consumo
Utilizzando un cursore specificato, utilizza i messaggi di un flusso nel servizio di streaming.
Per utilizzare i messaggi di un flusso, dovrai:
- creare un cursore;
- Utilizzare il cursore per ottenere o leggere i messaggi.
- Utilizzare il cursore restituito per continuare a leggere i messaggi.
È possibile utilizzare un singolo consumer per leggere i messaggi da uno o più flussi oppure utilizzare i gruppi di consumer per leggere i messaggi da un flusso.
Di seguito sono riportati i task che è possibile eseguire correlati al consumo dei messaggi.
- Creazione di un cursore
- Creazione di un cursore di gruppo
- Come leggere i messaggi
- Invio di un heartbeat
- Commit manuale di un offset
- Recupero dello stato corrente di un gruppo di consumer
- Aggiornamento di un gruppo di consumer
È inoltre possibile utilizzare Oracle Cloud Infrastructure Connector Hub per utilizzare i dati di un flusso e passare i messaggi allo storage degli oggetti o a qualsiasi altra destinazione hub connettore supportata.
È possibile mostrare i messaggi più recenti in un flusso utilizzando la console. Tuttavia, per utilizzare i messaggi del flusso, puoi utilizzare l'interfaccia CLI, l'API o un SDK per creare e utilizzare i cursori.
Per utilizzare i messaggi utilizzando gli SDK OCI, consulta la Guida per gli sviluppatori allo streaming. Vedere anche Sviluppo con Kafka e Streaming.
Criteri IAM necessari
Per utilizzare Oracle Cloud Infrastructure, un amministratore deve essere un membro di un gruppo a cui è stato concesso l'accesso di sicurezza in un criterio da un amministratore della tenancy. Questo accesso è necessario se si utilizza la console o l'API REST con un SDK, un'interfaccia CLI o un altro strumento. Se viene visualizzato un messaggio che informa che non si dispone dell'autorizzazione o che non si è autorizzati, verificare con l'amministratore della tenancy il tipo di accesso di cui si dispone e il compartimento in cui funziona l'accesso.
Per gli amministratori: il criterio in Consenti agli amministratori di streaming di gestire le risorse di streaming consente al gruppo specificato di eseguire qualsiasi operazione con le risorse del servizio di streaming e di streaming correlate.
È possibile creare un criterio che fornisca a un tenant l'accesso stream-pull per utilizzare i dati da un flusso in un altro tenant. Per ulteriori informazioni sui criteri di streaming, vedere Accesso alle risorse di streaming tra tenancy e Dettagli per il servizio di streaming.
Se non conosci i criteri, consulta la Panoramica sui criteri IAM.