diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java index 89e32b54af6d6..96e2bf9b98ebb 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java @@ -420,7 +420,7 @@ private void awaitStopConnector(String connName, long timeout) { } if (!connector.awaitShutdown(timeout)) { - log.error("Connector ‘{}’ failed to properly shut down, has become unresponsive, and " + log.error("Connector '{}' failed to properly shut down, has become unresponsive, and " + "may be consuming external resources. Correct the configuration for " + "this connector or remove the connector. After fixing the connector, it " + "may be necessary to restart this worker to release any consumed "