diff --git a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ConnectorDTO.java b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ConnectorDTO.java index ee891b10affe..80f0f024c8b7 100644 --- a/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ConnectorDTO.java +++ b/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ConnectorDTO.java @@ -39,6 +39,7 @@ public class ConnectorDTO extends ComponentDTO { private String validationStatus; private Boolean multipleVersionsAvailable; private Boolean extensionMissing; + private Boolean supportsBacklogReporting; private String configurationUrl; private String detailsUrl; @@ -161,6 +162,18 @@ public void setExtensionMissing(final Boolean extensionMissing) { this.extensionMissing = extensionMissing; } + /** + * @return whether the Connector implements {@code BacklogReportingConnector} and can report a backlog + */ + @Schema(description = "Whether the Connector implements BacklogReportingConnector and can report a backlog.") + public Boolean getSupportsBacklogReporting() { + return supportsBacklogReporting; + } + + public void setSupportsBacklogReporting(final Boolean supportsBacklogReporting) { + this.supportsBacklogReporting = supportsBacklogReporting; + } + @Schema(description = "The available actions that can be performed on this Connector.") public List getAvailableActions() { return availableActions; diff --git a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java index bc24e38ecda9..967abbd5a7a0 100644 --- a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java +++ b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java @@ -67,6 +67,7 @@ import org.apache.nifi.components.PropertyDescriptor; import org.apache.nifi.components.ValidationResult; import org.apache.nifi.components.connector.AssetReference; +import org.apache.nifi.components.connector.BacklogReportingConnector; import org.apache.nifi.components.connector.ConfigurationStep; import org.apache.nifi.components.connector.ConfigurationStepDependency; import org.apache.nifi.components.connector.ConnectorAction; @@ -5412,6 +5413,7 @@ public ConnectorDTO createConnectorDto(final ConnectorNode connector) { dto.setValidationErrors(convertValidationErrors(validationState.getValidationErrors())); dto.setType(connector.getCanonicalClassName()); dto.setExtensionMissing(connector.isExtensionMissing()); + dto.setSupportsBacklogReporting(connector.getConnector() instanceof BacklogReportingConnector); dto.setBundle(createBundleDto(connector.getBundleCoordinate())); dto.setState(connector.getCurrentState().name());