Skip to content

Commit c3b6e0e

Browse files
committed
fix String.format
1 parent b6fe5e9 commit c3b6e0e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -216,26 +216,26 @@ public void testKafkaSourceSinkWithTopicList() throws Exception {
216216
+ ")\n";
217217
final String createTopicListTable =
218218
String.format(
219-
"kafka",
220219
createTableTemplate,
220+
"kafka",
221221
KafkaDynamicTableFactory.IDENTIFIER,
222222
String.join(";", Arrays.asList(topic1, topic2)),
223223
bootstraps,
224224
groupId,
225225
formatOptions());
226226
final String createTopic1Table =
227227
String.format(
228-
"topic1",
229228
createTableTemplate,
229+
"topic1",
230230
KafkaDynamicTableFactory.IDENTIFIER,
231231
topic1,
232232
bootstraps,
233233
groupId,
234234
formatOptions());
235235
final String createTopic2Table =
236236
String.format(
237-
"topic2",
238237
createTableTemplate,
238+
"topic2",
239239
KafkaDynamicTableFactory.IDENTIFIER,
240240
topic2,
241241
bootstraps,

0 commit comments

Comments
 (0)