kpatelatwork commented on a change in pull request #10822:
URL: https://github.com/apache/kafka/pull/10822#discussion_r660781818
##########
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java
##########
@@ -357,6 +367,62 @@ public void validateConnectorConfig(Map<String, String>
connectorProps, Callback
});
}
+ /**
+ * Build the {@link RestartPlan} that describes what should and should not
be restarted given the restart request
+ * and the current status of the connector and task instances.
+ *
+ * @param request the restart request; may not be null
+ * @return the restart plan, or empty if this worker has no status for the
connector named in the request and therefore the
+ * connector cannot be restarted
+ */
+ public Optional<RestartPlan> buildRestartPlan(RestartRequest request) {
+ String connectorName = request.connectorName();
+ ConnectorStatus connectorStatus =
statusBackingStore.get(connectorName);
+ if (connectorStatus == null) {
+ return Optional.empty();
+ }
+
+ // If requested, mark the connector as restarting
+ AbstractStatus.State connectorState;
+ if (request.shouldRestartConnector(connectorStatus)) {
+ connectorState = AbstractStatus.State.RESTARTING;
+ } else {
+ connectorState = connectorStatus.state();
+ }
Review comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
