如何使用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()并向其传递一个主题资源，其中包含所有当前的主题配置以及更新后的配置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‘是一个主题配置。