sjyang18 commented on a change in pull request #4226:
URL: https://github.com/apache/nifi/pull/4226#discussion_r417661412



##########
File path: 
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/GetAzureEventHub.java
##########
@@ -103,16 +107,10 @@
             .description("The name of the shared access policy. This policy 
must have Listen claims.")
             .addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
             .expressionLanguageSupported(ExpressionLanguageScope.NONE)
-            .required(true)
-            .build();
-    static final PropertyDescriptor POLICY_PRIMARY_KEY = new 
PropertyDescriptor.Builder()
-            .name("Shared Access Policy Primary Key")
-            .description("The primary key of the shared access policy")
-            .addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
-            .expressionLanguageSupported(ExpressionLanguageScope.NONE)
-            .sensitive(true)
-            .required(true)
+            .required(false)
             .build();
+    static final PropertyDescriptor POLICY_PRIMARY_KEY =  
AzureEventHubUtils.POLICY_PRIMARY_KEY;
+    static final PropertyDescriptor USE_MANANGED_IDENTITY = 
AzureEventHubUtils.USE_MANAGED_IDENTITY;

Review comment:
       I fixed typos, not sure what went wrong with my IDE not to change in 
bulk update last time This time, I used grep to double check. 
   And, I cannot delete getConnectionString() without impacting existing test 
case and its BogusConnectionStringMockPutAzureEventHub. So, I decided to move 
AzureEventHubUtils.getSharedAccessSignatureConnectionString inside 
getConnectionString.  




----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to