Skip to content

Commit 90b178b

Browse files
authored
Pass topic-management.rebalance.interval.ms to MultiClusterTopicManagementService (linkedin#72)
1 parent 9999e04 commit 90b178b

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/main/java/com/linkedin/kmf/services/TopicManagementService.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,8 @@ private Map<String, Object> createMultiClusterTopicManagementServiceProps(Map<St
5252
Map<String, Object> serviceProps = new HashMap<>();
5353
serviceProps.put(MultiClusterTopicManagementServiceConfig.PROPS_PER_CLUSTER_CONFIG, configPerCluster);
5454
serviceProps.put(MultiClusterTopicManagementServiceConfig.TOPIC_CONFIG, props.get(TopicManagementServiceConfig.TOPIC_CONFIG));
55+
if (props.containsKey(MultiClusterTopicManagementServiceConfig.REBALANCE_INTERVAL_MS_CONFIG))
56+
serviceProps.put(MultiClusterTopicManagementServiceConfig.REBALANCE_INTERVAL_MS_CONFIG, props.get(MultiClusterTopicManagementServiceConfig.REBALANCE_INTERVAL_MS_CONFIG));
5557
return serviceProps;
5658
}
5759

0 commit comments

Comments
 (0)