root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: rename @returns to @return (#9808) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
dengziming 2021-01-03 21:04:28 +08:00 committed by GitHub
parent bdb29e42cb
commit 0e91d053f3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java
View File

@ -65,7 +65,7 @@ public interface Herder {
* Get a list of connectors currently running in this cluster. This is a full list of connectors in the cluster gathered
* from the current configuration. However, note
*
* @returns A list of connector names
* @return A list of connector names
* @throws org.apache.kafka.connect.runtime.distributed.RequestTargetException if this node can not resolve the request
* (e.g., because it has not joined the cluster or does not have configs in sync with the group) and it is
* not the leader or the task owner (e.g., task restart must be handled by the worker which owns the task)
@ -132,7 +132,7 @@ public interface Herder {
/**
* Get a list of connectors currently running in this cluster.
* @returns A list of connector names
* @return A list of connector names
*/
Collection<String> connectors();
@ -213,7 +213,7 @@ public interface Herder {
* @param delayMs delay before restart
* @param connName name of the connector
* @param cb callback to invoke upon completion
* @returns The id of the request
* @return The id of the request
*/
HerderRequest restartConnector(long delayMs, String connName, Callback<Void> cb);