[chore][exporter/googlecloudpubsub] update to cloud.google.com/go/pubsub/v2 (#44465)

#### Description
Update to cloud.google.com/go/pubsub/v2 package to keep Renovate bot
happy.

This PR is scoped to the `exporter/googlepubsubexporter`

#### Link to tracking issue
This PR fixes renovate trying to upgrade but can't because it requires
code changes:

#42871

And remove the Pubsub part in the combined deprecation fix PR:

#41646

#### Testing

Changed existing test to match the new API.

#### Documentation

No documentation change required.

Author: alexvanboxel

exporter/googlecloudpubsubexporter/exporter.go

@@ -10,7 +10,7 @@ import (
 	"fmt"
 	"time"
 
-	"cloud.google.com/go/pubsub/apiv1/pubsubpb"
+	"cloud.google.com/go/pubsub/v2/apiv1/pubsubpb"
 	"github.com/google/uuid"
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/pdata/plog"

exporter/googlecloudpubsubexporter/exporter_test.go

@@ -9,7 +9,7 @@ import (
 	"testing"
 	"time"
 
-	pb "cloud.google.com/go/pubsub/apiv1/pubsubpb"
+	pb "cloud.google.com/go/pubsub/v2/apiv1/pubsubpb"
 	"github.com/google/uuid"
 	"github.com/googleapis/gax-go/v2"
 	"github.com/stretchr/testify/assert"

exporter/googlecloudpubsubexporter/go.mod

@@ -3,7 +3,7 @@ module github.com/open-telemetry/opentelemetry-collector-contrib/exporter/google
 go 1.24.0
 
 require (
-	cloud.google.com/go/pubsub v1.49.0
+	cloud.google.com/go/pubsub/v2 v2.3.0
 	github.com/google/uuid v1.6.0
 	github.com/googleapis/gax-go/v2 v2.15.0
 	github.com/stretchr/testify v1.11.1

exporter/googlecloudpubsubexporter/go.sum

@@ -7,8 +7,8 @@ import (
 	"context"
 	"fmt"
 
-	pubsub "cloud.google.com/go/pubsub/apiv1"
-	"cloud.google.com/go/pubsub/apiv1/pubsubpb"
+	pubsub "cloud.google.com/go/pubsub/v2/apiv1"
+	"cloud.google.com/go/pubsub/v2/apiv1/pubsubpb"
 	"github.com/googleapis/gax-go/v2"
 	"google.golang.org/api/option"
 	"google.golang.org/grpc"
@@ -18,7 +18,7 @@ import (
 // publisherClient subset of `pubsub.PublisherClient`
 type publisherClient interface {
 	Close() error
-	Publish(ctx context.Context, req *pubsubpb.PublishRequest, opts ...gax.CallOption) (*pubsubpb.PublishResponse, error)
+	Publish(ctx context.Context, in *pubsubpb.PublishRequest, opts ...gax.CallOption) (*pubsubpb.PublishResponse, error)
 }
 
 // wrappedPublisherClient allows to override the close function
@@ -40,7 +40,8 @@ func newPublisherClient(ctx context.Context, config *Config, userAgent string) (
 		return nil, fmt.Errorf("failed preparing the gRPC client options to PubSub: %w", err)
 	}
 
-	client, err := pubsub.NewPublisherClient(ctx, clientOptions...)
+	// In new v2 client the Publish is moved to the TopicAdmin client
+	client, err := pubsub.NewTopicAdminClient(ctx, clientOptions...)
 	if err != nil {
 		return nil, fmt.Errorf("failed creating the gRPC client to PubSub: %w", err)
 	}

exporter/googlecloudpubsubexporter/publisher_client.go

@@ -6,7 +6,7 @@ package googlecloudpubsubexporter
 import (
 	"testing"
 
-	pubsub "cloud.google.com/go/pubsub/apiv1"
+	pubsub "cloud.google.com/go/pubsub/v2/apiv1"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 	"google.golang.org/api/option"
@@ -88,7 +88,7 @@ func TestNewPublisherClient(t *testing.T) {
 		client, err := newPublisherClient(ctx, cfg, "test-user-agent 6789")
 		assert.NoError(t, err)
 		require.NotEmpty(t, client)
-		assert.IsType(t, &pubsub.PublisherClient{}, client)
+		assert.IsType(t, &pubsub.TopicAdminClient{}, client)
 		assert.NoError(t, client.Close())
 	})
 
@@ -103,7 +103,7 @@ func TestNewPublisherClient(t *testing.T) {
 		client, err := newPublisherClient(ctx, cfg, "test-user-agent 6789")
 		assert.NoError(t, err)
 		require.NotEmpty(t, client)
-		assert.IsType(t, &pubsub.PublisherClient{}, client)
+		assert.IsType(t, &pubsub.TopicAdminClient{}, client)
 		assert.NoError(t, client.Close())
 	})