Simplify templating in log messages (#6133)
diff --git a/pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java b/pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java
index 613d4cc..5d5715e 100644
--- a/pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java
+++ b/pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java
@@ -55,7 +55,7 @@
private static RemovalListener<ClientConfigurationData, PulsarClientImpl> removalListener = notification -> {
ClientConfigurationData config = notification.getKey();
PulsarClientImpl client = notification.getValue();
- LOG.debug("Evicting pulsar client %s with config %s, due to %s",
+ LOG.debug("Evicting pulsar client {} with config {}, due to {}",
client.toString(), config.toString(), notification.getCause().toString());
close(config, client);
};
@@ -68,11 +68,9 @@
PulsarClientImpl client;
try {
client = new PulsarClientImpl(clientConfig);
- LOG.debug(String.format("Created a new instance of PulsarClientImpl for clientConf = %s",
- clientConfig.toString()));
+ LOG.debug("Created a new instance of PulsarClientImpl for clientConf = {}", clientConfig.toString());
} catch (PulsarClientException e) {
- LOG.error(String.format("Failed to create PulsarClientImpl for clientConf = %s",
- clientConfig.toString()));
+ LOG.error("Failed to create PulsarClientImpl for clientConf = {}", clientConfig.toString());
throw e;
}
return client;
@@ -84,10 +82,10 @@
private static void close(ClientConfigurationData clientConfig, PulsarClientImpl client) {
try {
- LOG.info(String.format("Closing the Pulsar client with conifg %s", clientConfig.toString()));
+ LOG.info("Closing the Pulsar client with config {}", clientConfig.toString());
client.close();
} catch (PulsarClientException e) {
- LOG.warn(String.format("Error while closing the Pulsar client ", clientConfig.toString()), e);
+ LOG.warn("Error while closing the Pulsar client with config {}", clientConfig.toString(), e);
}
}
