MINOR: Fix invalid {@param} Javadoc tags in streams and connect

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java

@@ -634,12 +634,12 @@ public ConfigProvider newConfigProvider(AbstractConfig config, String providerPr
 
     /**
      * If the given class names are available in the classloader, return a list of new configured
-     * instances. If the instances implement {@link Configurable}, they are configured with provided {@param config}
+     * instances. If the instances implement {@link Configurable}, they are configured with provided {@code config}
      *
      * @param klassNames         the list of class names of plugins that needs to instantiated and configured
      * @param config             the configuration containing the {@link org.apache.kafka.connect.runtime.Worker}'s configuration; may not be {@code null}
      * @param pluginKlass        the type of the plugin class that is being instantiated
-     * @return the instantiated and configured list of plugins of type <T>; empty list if the {@param klassNames} is {@code null} or empty
+     * @return the instantiated and configured list of plugins of type <T>; empty list if the {@code klassNames} is {@code null} or empty
      * @throws ConnectException if the implementation class could not be found
      */
     public <T> List<T> newPlugins(List<String> klassNames, AbstractConfig config, Class<T> pluginKlass) {

streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java

@@ -628,7 +628,7 @@ boolean canMoveStandbyTask(final KafkaStreamsState source,
 
     /**
      *
-     * @return the traffic cost of assigning this {@param task} to the client {@param streamsState}.
+     * @return the traffic cost of assigning this {@code task} to the client {@code streamsState}.
      */
     private static int getCrossRackTrafficCost(final Set<TaskTopicPartition> topicPartitions,
                                                final String clientRack,

streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java

@@ -65,7 +65,7 @@ public ClientTagAwareStandbyTaskAssignor(final BiFunction<ProcessId, ClientState
     }
 
     /**
-     * The algorithm distributes standby tasks for the {@param statefulTaskIds} over different tag dimensions.
+     * The algorithm distributes standby tasks for the {@code statefulTaskIds} over different tag dimensions.
      * For each stateful task, the number of standby tasks will be assigned based on configured {@link AssignmentConfigs#numStandbyReplicas()}.
      * Rack aware standby tasks distribution only takes into account tags specified via {@link AssignmentConfigs#rackAwareAssignmentTags()}.
      * Ideally, all standby tasks for any given stateful task will be located on different tag dimensions to have the best possible distribution.

streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java

@@ -170,8 +170,8 @@ boolean populateTopicsToDescribe(final Set<String> topicsToDescribe, final boole
     }
 
     /**
-     * This function populates the {@param racksForPartition} parameter passed into the function by using both
-     * the {@code Cluster} metadata as well as the {@param internalTopicManager} for topics that have stale
+     * This function populates the {@code racksForPartition} parameter passed into the function by using both
+     * the {@code Cluster} metadata as well as the {@code internalTopicManager} for topics that have stale
      * information.
      *
      * @return whether the operation successfully completed and the rack information is valid.
@@ -220,8 +220,8 @@ private boolean validateTopicPartitionRack(final boolean changelogTopics) {
     }
 
     /**
-     * Verifies that within the {@param racksForProcessConsumer}, a single process is only running on a single
-     * rack. This function mutates the parameter {@param racksForProcess} to contain the resulting process
+     * Verifies that within the {@code racksForProcessConsumer}, a single process is only running on a single
+     * rack. This function mutates the parameter {@code rackForProcess} to contain the resulting process
      * to rack mapping.
      *
      * @return true if the validation was successful, and false otherwise.