如何解决如何在使用 node-rdkafka 创建新主题时设置主题级别配置?
我一直在使用 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 来做到这一点
解决方法
我找到了解决方案。 有一个对象类型的属性“config”可用于此目的:
client.createTopic({
'topic': name,'num_partitions': partitions,'replication_factor': replicas,'config': {
'retention.ms': '60000'
}
}
这会将 retention.ms 设置为 60000 毫秒。请注意,'config' 参数中传递的所有键值对必须是字符串类型。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。