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



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

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

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

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

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

使用rd_kafka_AlterConfigs()并向其传递一个TOPIC资源,其中包含所有当前主题配置以及更新的配置retention.ms

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

是否也有一种方法可以使用c++API来映射它?在RdKafka::topic::create设置主题配置之前,我在这里发现了为什么conf对象不支持retention.mshttps://docs.confluent.io/platform/current/installation/configuration/topic-configs.html#retention.ms"retention.ms"是一个主题配置。

最新更新