Checkpoint interface
Denetim noktası, kullanıcı tarafından olay hub'ı örneğindeki bir tüketici grubunun belirli bir bölümünden başarıyla işlenen son olayı temsil etmek için kullanılır.
updateCheckpoint() sınıfındaki PartitionProcessor yöntemi kullanıcı tarafından çağrıldığında, dahili olarak bir Checkpoint oluşturulur. Daha sonra CheckpointManageroluştururken kullanıcı tarafından seçilen EventProcessor tarafından uygulanan depolama çözümünde depolanır.
Kullanıcıların Checkpoint doğrudan etkileşim kurması asla beklenmez. Bu arabirim, EventProcessor ve CheckpointManageriç ç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 <yournamespace.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 <yournamespace.servicebus.windows.net>
fullyQualifiedNamespace: string
Özellik Değeri
string
offset
Olayın uzaklığı.
offset: string
Özellik Değeri
string
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