Consumo de mensajes
Con un cursor especificado, consuma mensajes de un flujo en el servicio Streaming.
El consumo de mensajes de un flujo requiere que:
- Cree un cursor.
- Usar el cursor para obtener o leer mensajes.
- Utilice el cursor devuelto para seguir leyendo mensajes.
Puede utilizar un consumidor individual para leer mensajes de uno o más flujos, o utilizar grupos de consumidores para leer mensajes de un flujo.
A continuación, se muestran las tareas que puede realizar relacionadas con el consumo de mensajes.
- Creación de un Cursor
- Creación de un Cursor de Grupo
- Obtención (lectura) de mensajes
- Envío de latido
- Confirmación manual de una compensación
- Obtención del Estado Actual de un Grupo de Consumidores
- Actualización de un grupo de consumidores
You can also use Oracle Cloud Infrastructure Connector Hub to consume data from a stream and pass messages to Object Storage or any other supported Connector Hub target.
Puede mostrar los últimos mensajes de un flujo mediante la consola. Sin embargo, para consumir mensajes del flujo, utilice la CLI, la API o un SDK para crear y utilizar cursores.
Para consumir mensajes mediante los SDK de OCI, consulte la Guía para desarrolladores de Streaming. Consulte también Desarrollo con Kafka y Streaming.
Política de IAM necesaria
Para utilizar Oracle Cloud Infrastructure, un administrador debe ser miembro de un grupo al que un administrador de arrendamiento haya otorgado acceso de seguridad en una política . Este acceso es necesario tanto si utiliza la Consola como la API de REST con un SDK, una CLI u otra herramienta. Si recibe un mensaje que indica que no tiene permiso o no está autorizado, verifique con el administrador del arrendamiento el tipo de acceso que tiene y en qué compartimento trabaja el acceso.
Para los administradores: la política de Permitir a los administradores de flujos gestionar recursos de flujo permite al grupo especificado realizar todas las acciones con el flujo y los recursos del servicio Streaming relacionados.
Puede crear una política que otorgue a un inquilino acceso stream-pull para consumir datos de un flujo en otro inquilino. Para obtener más información sobre las políticas de Streaming, consulte Acceso a recursos de Streaming en arrendamientos y Detalles del servicio Streaming.
Si no está familiarizado con las políticas, consulte Visión general de las políticas de IAM.