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

Question

我们可以在 kafka 机器中使用以下命令来更新正在运行的 kafka 主题的保留时间：

bin/kafka-topics.sh --zookeeper <kafka_ip> --alter --topic <target_topic> --config retention.ms=86400000

但我不想登录到 kafka 机器并运行命令。 我只是想使用 C 或 C++ 来更改远程生产者机器中正在运行的 kafka 主题的 kafka 保留时间。

问题是：我们可以使用 librdkafka 中的 api 来更新正在运行的 kafka 主题的保留时间吗？

注意：现在我们可以使用 C/C++ 生成和使用 kafka 数据了。

Answer 1

使用 rd_kafka_AlterConfigs() 并将 TOPIC 资源传递给它，其中包含所有当前主题配置以及您更新的配置 retention.ms。

https://docs.confluent.io/platform/current/clients/librdkafka/rdkafka_8h.html#ade8d161dfb86a94179d286f36ec5b28e

Answer 2

还有没有办法使用 c++ API 来映射它？ 在 RdKafka::Topic::create 设置主题配置之前，为什么 conf 对象不支持'retention.ms'，正如我在这里找到的https://docs.confluent.io/platform/current/installation/configuration/topic-configs.html#retention.ms'retention.ms' 是一个主题配置。