diff --git 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 index 29ed7ea7..be6e66ea 100644 --- 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 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());