From 5d717f23434bc18e5d9317cfc196564a2e85fc23 Mon Sep 17 00:00:00 2001 From: Yash Mayya Date: Wed, 22 Nov 2023 21:52:56 +0000 Subject: [PATCH] MINOR: Fix broken method link in DistributedHerder::writeToConfigTopicAsLeader Javadoc (#14824) Reviewers: Chris Egerton --- .../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 8ae19dd3a7b..69fcf8d9ed9 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 @@ -1644,7 +1644,7 @@ public class DistributedHerder extends AbstractHerder implements Runnable { * exclusively by the leader. For example, {@link ConfigBackingStore#putTargetState(String, TargetState)} does not require this * method, as it can be invoked by any worker in the cluster. * @param write the action that writes to the config topic, such as {@link ConfigBackingStore#putSessionKey(SessionKey)} or - * {@link ConfigBackingStore#putConnectorConfig(String, Map)}. + * {@link ConfigBackingStore#putConnectorConfig(String, Map, TargetState)}. */ private void writeToConfigTopicAsLeader(Runnable write) { try {