diff --git a/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/ConsumeGCPubSub.java b/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/ConsumeGCPubSub.java index 9440a434b4..5693721be8 100644 --- a/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/ConsumeGCPubSub.java +++ b/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/ConsumeGCPubSub.java @@ -179,7 +179,7 @@ public class ConsumeGCPubSub extends AbstractGCPubSubProcessor { private String getSubscriptionName(ProcessContext context) { final String subscriptionName = context.getProperty(SUBSCRIPTION).evaluateAttributeExpressions().getValue(); - final String projectId = context.getProperty(PROJECT_ID).getValue(); + final String projectId = context.getProperty(PROJECT_ID).evaluateAttributeExpressions().getValue(); if (subscriptionName.contains("/")) { return ProjectSubscriptionName.parse(subscriptionName).toString(); diff --git a/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java b/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java index 3e8e0f8f14..a41a610b37 100644 --- a/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java +++ b/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java @@ -209,7 +209,7 @@ public class PublishGCPubSub extends AbstractGCPubSubProcessor{ private ProjectTopicName getTopicName(ProcessContext context) { final String topic = context.getProperty(TOPIC_NAME).evaluateAttributeExpressions().getValue(); - final String projectId = context.getProperty(PROJECT_ID).getValue(); + final String projectId = context.getProperty(PROJECT_ID).evaluateAttributeExpressions().getValue(); if (topic.contains("/")) { return ProjectTopicName.parse(topic);