ノードとカフカを操作するために node-rdkafka npm パッケージを使用しています。新しいトピックを作成するために、私は次のコードを使用しています:
ブローカー レベルで設定された既定の 7 日間をオーバーライドするために、トピック レベルのretention.msclient.createTopic({ topic: topic.name, num_partitions: _.get(topic, "partitions", 1), replication_factor: _.get(topic, "replicas", 3) }
を追加する必要があります。node-rdkafka を使用してこれを行う方法はありますか