Delphi librdkafka 获取当前分区偏移量

在Delphi中使用librdkafka库来获取当前分区的偏移量，通常需要使用librdkafka提供的API来完成。librdkafka是一个C语言库，提供了与Apache Kafka进行交互的功能。Delphi可以通过外部库调用或者使用支持C语言接口的第三方库来访问librdkafka的功能。

以下是一个基本步骤说明如何使用librdkafka在Delphi中获取当前分区的偏移量：

1. 初始化librdkafka库。
2. 配置librdkafka相关的配置参数，如Kafka服务器地址等。
3. 创建Kafka消费者，并订阅相关主题。
4. 调用相应的API查询特定主题分区的当前偏移量。

由于Delphi标准库中并没有直接支持librdkafka的功能，所以你需要查找或者创建一个Delphi的wrapper来实现对librdkafka的调用。这样的wrapper会提供一个接口，让你能够更容易地在Delphi中使用librdkafka。

以下是使用librdkafka C语言API获取当前分区偏移量的一个简单示例，这个示例仅供参考，因为它没有直接展示如何在Delphi中使用，而是展示了在C语言环境下的基本调用方式：

#include "librdkafka/rdkafka.h"

int main() {
    rd_kafka_t *rk;
    rd_kafka_conf_t *conf;
    const char *brokers = "localhost:9092";
    const char *topic_name = "my_topic";
    int32_t partition = 0; // 分区号
    int64_t offset;

    conf = rd_kafka_conf_new();
    // 配置Kafka服务器地址
    rd_kafka_conf_set(conf, "bootstrap.servers", brokers, NULL, 0);

    rk = rd_kafka_new(RD_KAFKA_CONSUMER, conf, NULL, 0);
    // 创建消费者
    rd_kafka_poll_set_consumer(rk);

    // 订阅主题
    rd_kafka_topic_partition_list_t *subscription = rd_kafka_topic_partition_list_new(1);
    subscription->elements[0].topic = strdup(topic_name);
    subscription->elements[0].partition = partition;
    subscription->elements[0].err = RD_KAFKAOFFSET_END;
    rd_kafka_subscribe(rk, subscription);

    // 获取当前偏移量
    rd_kafka_message_t *rk_message;
    rk_message = rd_kafka_consume(rk, partition, 1000 /* timeout MS */, NULL /* opaque */, 0 /* partition end */);
    if (rk_message && rk_message->err == RD_KAFKA_ERR_NO_ERROR) {
        offset = rk_message->offset;
        printf("Current offset for partition %d: %lld\n", rk_message->partition, offset);
    } else {
        fprintf(stderr, "Consume failed: %s\n", rd_kafka_message_errstr(rk_message));
    }

    // 清理资源
    rd_kafka_message_destroy(rk_message);
    rd_kafka_topic_partition_list_destroy(subscription);
    rd_kafka_destroy(rk);
    rd_kafka_conf_destroy(conf);

    return 0;
}

在Delphi中使用时，你需要找到或创建相应的Delphi代码来调用这些函数，并确保所有必要的内存和资源管理都被正确处理。