exceptionfactory commented on code in PR #7023:
URL: https://github.com/apache/nifi/pull/7023#discussion_r1131267043
##########
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/GetAzureEventHub.java:
##########
@@ -332,7 +385,13 @@ private EventHubConsumerClient
createEventHubConsumerClient(final ProcessContext
final AzureNamedKeyCredential azureNamedKeyCredential = new
AzureNamedKeyCredential(policyName, policyKey);
eventHubClientBuilder.credential(fullyQualifiedNamespace,
eventHubName, azureNamedKeyCredential);
}
- return eventHubClientBuilder.buildConsumerClient();
+
+ // Set Azure Event Hub Client Identifier using Processor Identifier
instead of default random UUID
+ final AmqpClientOptions clientOptions = new AmqpClientOptions();
+ clientOptions.setIdentifier(getIdentifier());
Review Comment:
Thanks for the suggestion, I agree it would be helpful to have the Node
Identifier included. I pushed an update to prefix the Client Identifier with
the Node Identifier when it is available in a clustered deployment.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
