如何在Kafka中获取消费者的最后承诺偏移量？

from tencentcloud.common import credential
from tencentcloud.common.exception.tencent_cloud_sdk_exception import TencentCloudSDKException
from tencentcloud.ckafka.v20190819 import ckafka_client, models

def get_last_committed_offset():
    # 实例化密钥对象
    cred = credential.Credential("your-secret-id", "your-secret-key")
    
    # 实例化 CKafka 客户端对象
    client = ckafka_client.CkafkaClient(cred, "ap-guangzhou")
    
    # 实例化请求对象
    req = models.DescribeGroupOffsetsRequest()
    
    # 设置请求参数
    req.Group = "your-consumer-group"
    req.Topic = "your-topic"
    
    try:
        # 发起请求
        resp = client.DescribeGroupOffsets(req)
        
        # 解析响应结果
        for offset in resp.OffsetDetails:
            partition = offset.Partition
            committed_offset = offset.Offset
            print(f"Partition: {partition}, Committed Offset: {committed_offset}")
    except TencentCloudSDKException as err:
        print(f"An error occurred: {err}")

# 调用函数获取最后承诺偏移量
get_last_committed_offset()