File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
src/main/java/org/sourcelab/kafka/connect/apiclient Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -209,6 +209,7 @@ public ConnectorStatus getConnectorStatus(final String connectorName) {
209209 * Requires Kafka-Connect 2.5.0+
210210 *
211211 * @param connectorName Name of connector.
212+ * @return Connector Topics response.
212213 */
213214 public ConnectorTopics getConnectorTopics (final String connectorName ) {
214215 return submitRequest (new GetConnectorTopics (connectorName ));
@@ -220,6 +221,7 @@ public ConnectorTopics getConnectorTopics(final String connectorName) {
220221 * Requires Kafka-Connect 2.5.0+
221222 *
222223 * @param connectorName Name of connector.
224+ * @return true on success.
223225 */
224226 public boolean resetConnectorTopics (final String connectorName ) {
225227 return submitRequest (new PutConnectorTopicsReset (connectorName ));
You can’t perform that action at this time.
0 commit comments