This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 5310b1b3a68 NIFI-16362 Added Connector Backlog Support Status (#11692)
5310b1b3a68 is described below
commit 5310b1b3a686a98a117df0d388ace4126b4dfa34
Author: Mark Payne <[email protected]>
AuthorDate: Fri Sep 18 17:57:45 2026 -0400
NIFI-16362 Added Connector Backlog Support Status (#11692)
Co-authored-by: Cursor <[email protected]>
Signed-off-by: David Handermann <[email protected]>
---
.../main/java/org/apache/nifi/web/api/dto/ConnectorDTO.java | 13 +++++++++++++
.../main/java/org/apache/nifi/web/api/dto/DtoFactory.java | 2 ++
2 files changed, 15 insertions(+)
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 ee891b10aff..80f0f024c8b 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 class ConnectorDTO extends ComponentDTO {
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<ConnectorActionDTO> 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 bc24e38ecda..967abbd5a7a 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.PropertyDependency;
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 final class DtoFactory {
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());
