From 570109a9da76a1aa26d581f309e278c4d73d1cc0 Mon Sep 17 00:00:00 2001
From: Ted Yu <yute@vmware.com>
Date: Thu, 23 Jan 2020 16:06:22 -0800
Subject: [PATCH] Correct exception message in DistributedHerder

---
 .../kafka/connect/runtime/distributed/DistributedHerder.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
index be3fbfcdfae08..9202a946b754e 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
@@ -699,7 +699,7 @@ public void deleteConnectorConfig(final String connName, final Callback<Created<
                     public Void call() throws Exception {
                         log.trace("Handling connector config request {}", connName);
                         if (!isLeader()) {
-                            callback.onCompletion(new NotLeaderException("Only the leader can set connector configs.", leaderUrl()), null);
+                            callback.onCompletion(new NotLeaderException("Only the leader can delete connector configs.", leaderUrl()), null);
                             return null;
                         }