(nifi) branch main updated: NIFI-12525: Added property migration for the removed Consumer Hostname property in ConsumeAzureEventHub

[pvillard]

This is an automated email from the ASF dual-hosted git repository.

pvillard 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 02d563eefc NIFI-12525: Added property migration for the removed 
Consumer Hostname property in ConsumeAzureEventHub
02d563eefc is described below

commit 02d563eefc0aaa23a15778a5cc15b5d549ed01c1
Author: Peter Turcsanyi <turcsa...@apache.org>
AuthorDate: Tue Dec 19 19:52:11 2023 +0100

    NIFI-12525: Added property migration for the removed Consumer Hostname 
property in ConsumeAzureEventHub
    
    Signed-off-by: Pierre Villard <pierre.villard...@gmail.com>
    
    This closes #8171.
---
 .../apache/nifi/processors/azure/eventhub/ConsumeAzureEventHub.java | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/ConsumeAzureEventHub.java
 
b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/ConsumeAzureEventHub.java
index fe182e55db..4d99a53fae 100644
--- 
a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/ConsumeAzureEventHub.java
+++ 
b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/ConsumeAzureEventHub.java
@@ -51,6 +51,7 @@ import org.apache.nifi.expression.ExpressionLanguageScope;
 import org.apache.nifi.flowfile.FlowFile;
 import org.apache.nifi.flowfile.attributes.CoreAttributes;
 import org.apache.nifi.logging.ComponentLog;
+import org.apache.nifi.migration.PropertyConfiguration;
 import org.apache.nifi.processor.AbstractSessionFactoryProcessor;
 import org.apache.nifi.processor.ProcessContext;
 import org.apache.nifi.processor.ProcessSession;
@@ -329,6 +330,11 @@ public class ConsumeAzureEventHub extends 
AbstractSessionFactoryProcessor implem
         return isRecordReaderSet && isRecordWriterSet ? RECORD_RELATIONSHIPS : 
RELATIONSHIPS;
     }
 
+    @Override
+    public void migrateProperties(final PropertyConfiguration config) {
+        config.removeProperty("event-hub-consumer-hostname");
+    }
+
     @Override
     protected Collection<ValidationResult> customValidate(ValidationContext 
validationContext) {
         final List<ValidationResult> results = new ArrayList<>();