Skip to content
Snippets Groups Projects
Commit 7c00045f authored by Sören Henning's avatar Sören Henning
Browse files

Fix project name

parent 5cd0c321
No related branches found
No related tags found
1 merge request!247Draft: Add Pub/Sub source for Beam
Pipeline #7211 passed
......@@ -61,7 +61,7 @@ public class PipelineFactory extends AbstractPipelineFactory {
if (subscription == null) {
activePowerRecords = pipeline.apply(PubSubSource.forTopic(topic, project));
} else {
activePowerRecords = pipeline.apply(PubSubSource.forSubscription(topic, subscription));
activePowerRecords = pipeline.apply(PubSubSource.forSubscription(project, subscription));
}
} else {
final KafkaActivePowerTimestampReader kafka = super.buildKafkaReader();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment