Nachrichten konsumieren

Verwenden Sie einen angegebenen Cursor, um Nachrichten aus einem Stream im Streaming-Service zu konsumieren.

Um Nachrichten aus einem Stream zu konsumieren, müssen Sie folgende Schritte ausführen:

  • Cursor erstellen
  • Nachrichten mit dem Cursor abrufen oder lesen.
  • Den zurückgegebenen Cursor verwenden, um mit dem Lesen von Nachrichten fortzufahren

Sie können Nachrichten mit einem einzelnen Consumer aus einem oder mehreren Streams lesen oder Nachrichten mit Consumer-Gruppen aus einem Stream lesen.

Im Folgenden finden Sie Aufgaben, die Sie im Zusammenhang mit dem Konsumieren von Nachrichten ausführen können.

Tipp

Sie können Oracle Cloud Infrastructure Connector Hub auch verwenden, um Daten aus einem Stream zu konsumieren und Nachrichten an Object Storage oder an ein anderes unterstütztes Connector Hub-Ziel zu übergeben.

Sie können die neuesten Nachrichten in einem Stream anzeigen, indem Sie die Konsole verwenden. Um jedoch Nachrichten aus dem Stream zu konsumieren, verwenden Sie die CLI, die API oder ein SDK, um Cursor zu erstellen und zu verwenden.

Informationen, wie Sie Nachrichten mit OCI-SDKs konsumieren, finden Sie in der Entwicklerdokumentation für Streaming. Siehe auch Mit Kafka und Streaming Entwickeln.

Erforderliche IAM-Policy

Um Oracle Cloud Infrastructure verwenden zu können, muss ein Administrator Mitglied einer Gruppe sein, der Sicherheitszugriff in einer Policy von einem Mandantenadministrator erteilt wurde. Dieser Zugriff ist unabhängig davon erforderlich, ob Sie die Konsole oder die REST-API mit einem SDK, einer CLI oder einem anderen Tool verwenden. Wenn Sie eine Meldung erhalten, dass Sie keine Berechtigung haben oder nicht autorisiert sind, fragen sie den Mandantenadministrator, welcher Zugriffstyp Ihnen zugewiesen wurde und In welchem Compartment Ihr Zugriff funktioniert.

Für Administratoren: Mit der unter Verwalten von Streaming-Ressourcen durch Streaming-Administratoren zulassen beschriebenen Policy kann die angegebene Gruppe alle Aktionen mit Streaming und zugehörigen Streaming-Serviceressourcen ausführen.

Sie können eine Policy erstellen, die einem Mandanten stream-pull-Zugriff zum Konsumieren von Daten aus einem Stream in einem anderen Mandanten erteilt. Weitere Informationen zu Streaming-Policys finden Sie unter Auf Streaming-Ressourcen mandantenübergreifend zugreifen und Details zum Streaming-Service.

Wenn Sie mit Policys noch nicht vertraut sind, finden Sie weitere Informationen unter Überblick über IAM-Policys.