diff --git a/pubsub/api/src/update_topic_type.php b/pubsub/api/src/update_topic_type.php new file mode 100644 index 0000000000..8d179a719c --- /dev/null +++ b/pubsub/api/src/update_topic_type.php @@ -0,0 +1,73 @@ + $projectId, + ]); + + $topic = $pubsub->topic($topicName); + + $topic->update([ + 'ingestionDataSourceSettings' => [ + 'aws_kinesis' => [ + 'stream_arn' => $streamArn, + 'consumer_arn' => $consumerArn, + 'aws_role_arn' => $awsRoleArn, + 'gcp_service_account' => $gcpServiceAccount + ] + ] + ], [ + 'updateMask' => [ + 'ingestionDataSourceSettings' + ] + ]); + + printf('Topic updated: %s' . PHP_EOL, $topic->name()); +} +# [END pubsub_update_topic_type] +require_once __DIR__ . '/../../../testing/sample_helpers.php'; +\Google\Cloud\Samples\execute_sample(__FILE__, __NAMESPACE__, $argv); diff --git a/pubsub/api/test/pubsubTest.php b/pubsub/api/test/pubsubTest.php index 5cf0e45b2f..cb3375a396 100644 --- a/pubsub/api/test/pubsubTest.php +++ b/pubsub/api/test/pubsubTest.php @@ -600,4 +600,28 @@ public function testOptimisticSubscribe() $this->assertMatchesRegularExpression('/Subscription deleted:/', $output); $this->assertMatchesRegularExpression(sprintf('/%s/', $subcriptionId), $output); } + + public function testUpdateTopicType() + { + $topic = 'test-topic-' . rand(); + $output = $this->runFunctionSnippet('create_topic', [ + self::$projectId, + $topic, + ]); + + $this->assertMatchesRegularExpression('/Topic created:/', $output); + $this->assertMatchesRegularExpression(sprintf('/%s/', $topic), $output); + + $output = $this->runFunctionSnippet('update_topic_type', [ + self::$projectId, + $topic, + 'arn:aws:kinesis:us-west-2:111111111111:stream/fake-stream-name', + 'arn:aws:kinesis:us-west-2:111111111111:stream/fake-stream-name/consumer/consumer-1:1111111111', + self::$awsRoleArn, + self::$gcpServiceAccount + ]); + + $this->assertMatchesRegularExpression('/Topic updated:/', $output); + $this->assertMatchesRegularExpression(sprintf('/%s/', $topic), $output); + } }