This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new 79ceb456 refactor: migrate String.format to String.formatted (Java
15+) (#575)
79ceb456 is described below
commit 79ceb456a1a07b4ebf7fb6e007f074c972574367
Author: He-Pin(kerr) <[email protected]>
AuthorDate: Fri Jun 26 18:23:09 2026 +0800
refactor: migrate String.format to String.formatted (Java 15+) (#575)
Motivation:
Java 15 introduced String.formatted() as an instance method counterpart
to String.format(), providing cleaner and more readable string formatting.
Modification:
Replace String.format("literal", args) with "literal".formatted(args)
in Kafka testkit container classes.
Result:
More concise and idiomatic Java code leveraging Java 15+ API.
---
.../apache/pekko/kafka/testkit/internal/KafkaContainerCluster.java | 2 +-
.../pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java | 4 ++--
.../apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java | 2 +-
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/KafkaContainerCluster.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/KafkaContainerCluster.java
index 7d1cee3b..1e154198 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/KafkaContainerCluster.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/KafkaContainerCluster.java
@@ -184,7 +184,7 @@ public class KafkaContainerCluster implements Startable {
public String getInternalNetworkBootstrapServers() {
return IntStream.range(0, this.brokersNum)
- .mapToObj(brokerNum -> String.format("broker-%s:%s", brokerNum,
"9092"))
+ .mapToObj(brokerNum -> "broker-%s:%s".formatted(brokerNum, "9092"))
.collect(Collectors.joining(","));
}
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
index 3e820311..c5be7232 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java
@@ -170,7 +170,7 @@ public class PekkoConnectorsKafkaContainer extends
GenericContainer<PekkoConnect
if (port == PORT_NOT_ASSIGNED) {
throw new IllegalStateException("You should start Kafka container
first");
}
- return String.format("PLAINTEXT://%s:%s", getHost(), port);
+ return "PLAINTEXT://%s:%s".formatted(getHost(), port);
}
public String getJmxServiceUrl() {
@@ -178,7 +178,7 @@ public class PekkoConnectorsKafkaContainer extends
GenericContainer<PekkoConnect
throw new IllegalStateException("You should start Kafka container
first");
}
- return String.format("service:jmx:rmi:///jndi/rmi://%s:%s/jmxrmi",
getHost(), jmxPort);
+ return "service:jmx:rmi:///jndi/rmi://%s:%s/jmxrmi".formatted(getHost(),
jmxPort);
}
@Override
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java
index 722bfd6b..ac27519a 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java
@@ -48,6 +48,6 @@ public class SchemaRegistryContainer extends
GenericContainer<SchemaRegistryCont
}
public String getSchemaRegistryUrl() {
- return String.format("http://%s:%s";, getHost(),
getMappedPort(SCHEMA_REGISTRY_PORT));
+ return "http://%s:%s".formatted(getHost(),
getMappedPort(SCHEMA_REGISTRY_PORT));
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
