ydb-platform / ydb-go-sdk

Pure Go native and database/sql driver for YDB
https://ydb.tech
Apache License 2.0
133 stars 69 forks source link

Maintain PartitionConsumerStats extraction #1243

Open DenisEvd opened 1 month ago

DenisEvd commented 1 month ago

Feature Request

Describe the Feature Request

Add behavior to the SDK to get information about the progress of reading a partition

Describe Preferred Solution

API has PartitionConsumerStats

Additional Context

We need to get the latest committed offset for some partition, so that after reading the batch of messages from this partition, we can check if we have lost any messages