This is an automated email from the ASF dual-hosted git repository.
cegerton pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.3 by this push:
new 1433aa24cce MINOR: Fix error check in Connect Worker zombie fencing
(#13392)
1433aa24cce is described below
commit 1433aa24cce1bdfb4a3084e847c3fce66ed18e43
Author: Yash Mayya <[email protected]>
AuthorDate: Tue Mar 14 21:39:52 2023 +0530
MINOR: Fix error check in Connect Worker zombie fencing (#13392)
---
.../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 22717fd2bb4..79d944aa97b 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
@@ -737,7 +737,7 @@ public class Worker {
FenceProducersOptions fencingOptions = new
FenceProducersOptions()
.timeoutMs((int)
ConnectResource.DEFAULT_REST_REQUEST_TIMEOUT_MS);
return admin.fenceProducers(transactionalIds,
fencingOptions).all().whenComplete((ignored, error) -> {
- if (error != null)
+ if (error == null)
log.debug("Finished fencing out {} task producers
for source connector {}", numTasks, connName);
Utils.closeQuietly(admin, "Zombie fencing admin for
connector " + connName);
});