EventHubConsumerGroup.CreateReceiverAsync Methode
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Überlädt
CreateReceiverAsync(String, String, Boolean, Int64, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, String, Boolean, Int64, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, string startingOffset, bool offsetInclusive, long epoch, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * string * bool * int64 * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingOffset As String, offsetInclusive As Boolean, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- startingOffset
- String
Der Startoffset, ab dem mit dem Empfang von Nachrichten begonnen werden soll.
- offsetInclusive
- Boolean
Ein boolescher Wert, der angibt, ob startingOffset als inklusiver Offset behandelt wird, was bedeutet, dass das erste zurückgegebene Ereignis das Ereignis ist, das den Startoffset enthält. Normalerweise ist das erste zurückgegebene Ereignis das Ereignis nach dem Startoffset.
- epoch
- Int64
Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Gilt für:
CreateReceiverAsync(String, String, Int64, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, String, Int64, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, string startingOffset, long epoch, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * string * int64 * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingOffset As String, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- startingOffset
- String
Der Startoffset, ab dem mit dem Empfang von Nachrichten begonnen werden soll. Informationen zum Angeben des Anfangs des Datenstroms finden Sie unter StartOfStream.
- epoch
- Int64
Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Gilt für:
CreateReceiverAsync(String, String, Boolean, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, String, Boolean, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, string startingOffset, bool offsetInclusive, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * string * bool * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingOffset As String, offsetInclusive As Boolean, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- startingOffset
- String
Der Startoffset, ab dem mit dem Empfang von Nachrichten begonnen werden soll.
- offsetInclusive
- Boolean
Ein boolescher Wert, der angibt, ob startingOffset als inklusiver Offset behandelt wird, was bedeutet, dass das erste zurückgegebene Ereignis das Ereignis ist, das den Startoffset enthält. Normalerweise ist das erste zurückgegebene Ereignis das Ereignis nach dem Startoffset.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Gilt für:
CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, DateTime, Int64, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, DateTime startingDateTimeUtc, long epoch, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * DateTime * int64 * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingDateTimeUtc As DateTime, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- startingDateTimeUtc
- DateTime
Die UTC-Startzeit für den Empfang von Nachrichten.
- epoch
- Int64
Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Hinweise
Der Dienst verwendet dies startingDateTimeUtc nur als Näherung, wenn das nächste zu übermittelnde Ereignis bestimmt wird.
Beachten Sie, dass zwischen Clientzeit und Dienstzeit eine Abweichung der Uhr auftreten kann. Daher sollte die Benutzeranwendung so konzipiert werden, dass sie duplizierungen bei der Ereignisübermittlung verarbeitet.
Gilt für:
CreateReceiverAsync(String, DateTime, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, DateTime, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, DateTime startingDateTimeUtc, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * DateTime * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingDateTimeUtc As DateTime, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- startingDateTimeUtc
- DateTime
Die UTC-Startzeit für den Empfang von Nachrichten.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Hinweise
Der Dienst verwendet dies startingDateTimeUtc nur als Näherung, wenn das nächste zu übermittelnde Ereignis bestimmt wird.
Beachten Sie, dass zwischen Clientzeit und Dienstzeit eine Abweichung der Uhr auftreten kann. Daher sollte die Benutzeranwendung so konzipiert werden, dass sie duplizierungen bei der Ereignisübermittlung verarbeitet.
Gilt für:
CreateReceiverAsync(String, String, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, string startingOffset, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * string * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingOffset As String, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- startingOffset
- String
Der Startoffset, ab dem mit dem Empfang von Nachrichten begonnen werden soll.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Gilt für:
CreateReceiverAsync(String, Int64, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, Int64, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, long epoch, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * int64 * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- epoch
- Int64
Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Hinweise
Wenn der EventHubConsumerGroup Prüfpunkt aktiviert ist, erhält der Empfänger die nächste Nachricht vom Prüfpunktoffset. Wenn der Prüfpunkt deaktiviert ist, erhält der Empfänger eine Nachricht vom Anfang des Ereignisdatenstroms, wie durch die Nachrichtenaufbewahrungsrichtlinie des Event Hubs festgelegt.
Gilt für:
CreateReceiverAsync(String, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Hinweise
Wenn der EventHubConsumerGroup Prüfpunkt aktiviert ist, löst diese Überladung immer InvalidOperationException aus, da die consumerGroup für Prüfpunkte aktiviert ist, um eine Epoche zu funktionieren (verwenden Sie die Überladung, die Epoche als Eingabeargument bereitstellt). Wenn der Prüfpunkt deaktiviert ist, erhält der Empfänger eine Nachricht vom Anfang des Ereignisdatenstroms, wie durch die Nachrichtenaufbewahrungsrichtlinie des Event Hubs festgelegt.
Gilt für:
CreateReceiverAsync(String, EventPosition, Nullable<Int64>, ReceiverOptions)
Asynchrone Version von CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, Microsoft.ServiceBus.Messaging.EventPosition position, long? epoch = default, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * Microsoft.ServiceBus.Messaging.EventPosition * Nullable<int64> * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, position As EventPosition, Optional epoch As Nullable(Of Long) = Nothing, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parameter
- partitionId
- String
Die ID der Partition.
- position
- EventPosition
Die , EventPosition ab der nachrichten empfangen werden sollen.
Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.
- receiverOptions
- ReceiverOptions
Optionen für einen Event Hub-Empfänger.
Gibt zurück
Gibt Task<TResult>zurück.
Gilt für:
Azure SDK for .NET
Feedback
Bald verfügbar: Im Laufe des Jahres 2024 werden wir GitHub-Issues stufenweise als Feedbackmechanismus für Inhalte abbauen und durch ein neues Feedbacksystem ersetzen. Weitere Informationen finden Sie unter https://aka.ms/ContentUserFeedback.
Feedback senden und anzeigen für