如何使用librdkafka更改运行中的kafka主题的保留时间

rd_kafka_t *rk;
rd_kafka_conf_t *conf;
rd_kafka_topic_conf_t *topic_conf;
rd_kafka_resp_err_t err;

conf = rd_kafka_conf_new();
topic_conf = rd_kafka_topic_conf_new();

// 设置Kafka集群的地址和其他配置
rd_kafka_conf_set(conf, "bootstrap.servers", "kafka_server:9092", NULL);

// 创建Kafka消费者对象
rk = rd_kafka_new(RD_KAFKA_CONSUMER, conf, errstr, sizeof(errstr));
if (!rk) {
    fprintf(stderr, "Failed to create consumer: %s\n", errstr);
    exit(1);
}

// 创建Kafka管理器对象
rd_kafka_admin_options_t *admin_options;
admin_options = rd_kafka_admin_options_new(rk, RD_KAFKA_ADMIN_OP_ALTERCONFIGS);

// 设置要更改的主题名称
const char *topic_name = "your_topic_name";

// 设置要更改的配置项和值
const char *config_name = "retention.ms";
const char *config_value = "86400000"; // 保留时间为1天

// 添加要更改的配置项和值
rd_kafka_AdminOptions_set_config(admin_options, topic_name, config_name, config_value);

// 提交更改请求
rd_kafka_resp_err_t err = rd_kafka_admin_alter_configs(admin_options, NULL, errstr, sizeof(errstr));
if (err != RD_KAFKA_RESP_ERR_NO_ERROR) {
    fprintf(stderr, "Failed to alter topic configuration: %s\n", errstr);
    exit(1);
}

// 销毁对象
rd_kafka_admin_options_destroy(admin_options);
rd_kafka_destroy(rk);