This is an automated email from the ASF dual-hosted git repository.
kkarantasis pushed a commit to branch 3.2
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.2 by this push:
new 04e6b6e40e MINOR: Replace left single quote with single quote in
Connect worker's log message (#12201)
04e6b6e40e is described below
commit 04e6b6e40effc8aa5b521ca443136062fbce3448
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 4adf6ff5e0..61484d36f1 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
@@ -405,7 +405,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 "
