8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-01-04 20:02:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #37 from ZQKC/master

Browse Source 
fix retention.ms when execute topic order
This commit is contained in:
ZQKC
2020-07-01 11:01:38 +08:00
committed by GitHub
parent d4dc4b9d0a 0cd31e0545
commit 5e24f6b044
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
web/src/main/java/com/xiaojukeji/kafka/manager/web/api/versionone/OrderController.java
View File

@@ -176,7 +176,7 @@ public class OrderController {
TopicDO topicInfoDO = OrderConverter.convert2TopicInfoDO(orderTopicDO); TopicDO topicInfoDO = OrderConverter.convert2TopicInfoDO(orderTopicDO);
List<Integer> brokerIdList = regionService.getFullBrokerId(clusterDO.getId(), reqObj.getRegionIdList(), reqObj.getBrokerIdList()); List<Integer> brokerIdList = regionService.getFullBrokerId(clusterDO.getId(), reqObj.getRegionIdList(), reqObj.getBrokerIdList());
Properties topicConfig = new Properties(); Properties topicConfig = new Properties();
topicConfig.setProperty("retention.ms", String.valueOf(reqObj.getRetentionTime())); topicConfig.setProperty("retention.ms", String.valueOf(reqObj.getRetentionTime() * 60 * 60 * 1000));
try { try {
TopicMetadata topicMetadata = new TopicMetadata(); TopicMetadata topicMetadata = new TopicMetadata();
topicMetadata.setTopic(orderTopicDO.getTopicName()); topicMetadata.setTopic(orderTopicDO.getTopicName());