问题描述
我一直在使用 node-rdkafka npm 包来处理 node 和 kafka。
为了创建一个新主题，我一直在使用以下代码：
client.createTopic({ topic: topic.name,num_partitions: _.get(topic,"partitions",1),replication_factor: _.get(topic,"replicas",3) }
我需要添加主题级别 retention.ms 以覆盖在代理级别设置的默认 7 天。有没有办法使用 node-rdkafka 来做到这一点
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）