Skip to content
This repository was archived by the owner on Dec 14, 2022. It is now read-only.

Commit cb7e76f

Browse files
author
gavingaozhangmin
committed
fix code style
1 parent f68f01c commit cb7e76f

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/internal/PulsarClientUtils.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -72,12 +72,8 @@ public static ClientConfigurationData newClientConf(String serviceUrl, Propertie
7272
public static Map<String, Object> getClientParams(Map<String, String> parameters) {
7373
return parameters.keySet().stream()
7474
.filter(k -> k.startsWith(PulsarOptions.PULSAR_CLIENT_OPTION_KEY_PREFIX))
75-
.collect(
76-
Collectors.toMap(
77-
k ->
78-
k.substring(
79-
PulsarOptions.PULSAR_CLIENT_OPTION_KEY_PREFIX
80-
.length()),
81-
k -> parameters.get(k)));
75+
.collect(Collectors.toMap(
76+
k -> k.substring(PulsarOptions.PULSAR_CLIENT_OPTION_KEY_PREFIX.length()),
77+
k -> parameters.get(k)));
8278
}
8379
}

0 commit comments

Comments
 (0)