fix retentionTime when create topic

0cd31e05 · zengqiao · e4dc4bae · 0cd31e05
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/OrderController.java ...eji/kafka/manager/web/api/versionone/OrderController.java +1 -1

未找到文件。
--- a/web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/OrderController.java
+++ b/web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/OrderController.java
@@ -176,7 +176,7 @@ public class OrderController {
        TopicDO topicInfoDO = OrderConverter.convert2TopicInfoDO(orderTopicDO);
        List<Integer> brokerIdList = regionService.getFullBrokerId(clusterDO.getId(), reqObj.getRegionIdList(), reqObj.getBrokerIdList());
        Properties topicConfig = new Properties();
-        topicConfig.setProperty("retention.ms", String.valueOf(reqObj.getRetentionTime()));
+        topicConfig.setProperty("retention.ms", String.valueOf(reqObj.getRetentionTime() * 60 * 60 * 1000));
        try {
            TopicMetadata topicMetadata = new TopicMetadata();
            topicMetadata.setTopic(orderTopicDO.getTopicName());