This is an automated email from the ASF dual-hosted git repository.
kkarantasis pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 6efde847ca MINOR: Replace left single quote with single quote in
Connect worker's log message (#12201)
6efde847ca is described below
commit 6efde847ca1bbf25e6eb8a306e4ce584319c8c12
Author: nicolasguyomar <[email protected]>
AuthorDate: Wed May 25 19:40:46 2022 +0200
MINOR: Replace left single quote with single quote in Connect worker's log
message (#12201)
Minor change to use ' and not LEFT SINGLE QUOTATION MARK in this log
message, as it's the only place we are using such a quote and it can break
ingestion pipelines
Reviewers: Kvicii <[email protected]>, Divij Vaidya <[email protected]>,
Konstantine Karantasis <[email protected]>
---
.../runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 89e32b54af..96e2bf9b98 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 @@ public class Worker {
}
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 "
