Checkpoint interface
Denetim noktası, bir Olay Hub'ı örneğindeki bir tüketici grubunun belirli bir bölümünden kullanıcı tarafından başarıyla işlenen son olayı temsil etmeye yöneliktir.
sınıfındaki updateCheckpoint()
PartitionProcessor
yöntemi kullanıcı tarafından çağrıldığında, dahili olarak bir Checkpoint
oluşturulur. Ardından, bir oluştururken EventProcessor
kullanıcı tarafından seçilen tarafından CheckpointManager
uygulanan depolama çözümünde depolanır.
Kullanıcıların doğrudan etkileşim Checkpoint
kurması asla beklenmez. Bu arabirim, ve CheckpointManager
'nin EventProcessor
iç çalışmalarını desteklemek için mevcuttur.
Özellikler
consumer |
Tüketici grubu adı |
event |
Olay hub'ı adı |
fully |
Tam Event Hubs ad alanı. Bu büyük olasılıkla .servicebus.windows.net |
offset | Olayın uzaklığı. |
partition |
Olay Hub'ı bölümünün tanımlayıcısı |
sequence |
Olayın sıra numarası |
Özellik Ayrıntıları
consumerGroup
Tüketici grubu adı
consumerGroup: string
Özellik Değeri
string
eventHubName
Olay hub'ı adı
eventHubName: string
Özellik Değeri
string
fullyQualifiedNamespace
Tam Event Hubs ad alanı. Bu büyük olasılıkla .servicebus.windows.net
fullyQualifiedNamespace: string
Özellik Değeri
string
offset
Olayın uzaklığı.
offset: number
Özellik Değeri
number
partitionId
Olay Hub'ı bölümünün tanımlayıcısı
partitionId: string
Özellik Değeri
string
sequenceNumber
Olayın sıra numarası
sequenceNumber: number
Özellik Değeri
number