chore(otlp): use buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1

mmatczuk · mmatczuk · commit 94bc64a6f88b · 2026-01-21T12:52:18.000+01:00
diff --git a/go.mod b/go.mod
@@ -19,6 +19,7 @@ ignore (
 require (
 	buf.build/gen/go/bufbuild/reflect/connectrpc/go v1.19.1-20240117202343-bf8f65e8876c.2
 	buf.build/gen/go/bufbuild/reflect/protocolbuffers/go v1.36.10-20240117202343-bf8f65e8876c.1
+	buf.build/gen/go/redpandadata/otel/protocolbuffers/go v1.36.11-20251216164002-58c749b888d8.1
 	buf.build/go/hyperpb v0.1.3
 	cloud.google.com/go/aiplatform v1.104.0
 	cloud.google.com/go/bigquery v1.71.0
diff --git a/go.sum b/go.sum
@@ -6,6 +6,8 @@ buf.build/gen/go/bufbuild/reflect/connectrpc/go v1.19.1-20240117202343-bf8f65e88
 buf.build/gen/go/bufbuild/reflect/connectrpc/go v1.19.1-20240117202343-bf8f65e8876c.2/go.mod h1:ZGK0ces5GRXffhjOIcqSMOVV3Y3rgIwnvMJfZ/JltTg=
 buf.build/gen/go/bufbuild/reflect/protocolbuffers/go v1.36.10-20240117202343-bf8f65e8876c.1 h1:Z6b/hsRyrX22pN5cI7n6mDwhj38smtNfV21fhj+4gPk=
 buf.build/gen/go/bufbuild/reflect/protocolbuffers/go v1.36.10-20240117202343-bf8f65e8876c.1/go.mod h1:dDSnTB/bSMAA9z59+0E2JWab9LyGnb+spW8nrVeEAqA=
+buf.build/gen/go/redpandadata/otel/protocolbuffers/go v1.36.11-20251216164002-58c749b888d8.1 h1:4jqc94IBC9Ea9GaMbmgfhczXZzCkA4ZWfon3/uI3KV0=
+buf.build/gen/go/redpandadata/otel/protocolbuffers/go v1.36.11-20251216164002-58c749b888d8.1/go.mod h1:akvBCH3f6fL10sDu4NppgjHrQITLe1m5YWLt/yiLEKI=
 buf.build/go/hyperpb v0.1.3 h1:wiw2F7POvAe2VA2kkB0TAsFwj91lXbFrKM41D3ZgU1w=
 buf.build/go/hyperpb v0.1.3/go.mod h1:IHXAM5qnS0/Fsnd7/HGDghFNvUET646WoHmq1FDZXIE=
 buf.build/go/protovalidate v0.14.0 h1:kr/rC/no+DtRyYX+8KXLDxNnI1rINz0imk5K44ZpZ3A=
@@ -2024,8 +2026,7 @@ github.com/redpanda-data/common-go/authz v0.2.0 h1:KYBu/+eIdFlaR8qJXn5I52AJ9Zo4K
 github.com/redpanda-data/common-go/authz v0.2.0/go.mod h1:x1C0YQ5NhCg2uj09Oz0bwMwDTkazK8lwxfZshE5Lf3s=
 github.com/redpanda-data/common-go/license v0.0.0-20260109170727-1dd9f5d22ee1 h1:Qr6sK5Qmznbwtk4AKgd6086RM+uA/Z4lO/r2aCDxx+c=
 github.com/redpanda-data/common-go/license v0.0.0-20260109170727-1dd9f5d22ee1/go.mod h1:F1fp8xVNS2UwWFosOjJ9+5jaEZnXSjB9AdHk2R9XlpI=
-github.com/redpanda-data/common-go/redpanda-otel-exporter v0.3.1-0.20260120073450-935d3dd3d6c1 h1:jQLTLBWJqOyMAZi9YFx8nsgZ7fOq+DYZsSF7zM+hb7o=
-github.com/redpanda-data/common-go/redpanda-otel-exporter v0.3.1-0.20260120073450-935d3dd3d6c1/go.mod h1:kzFoUX1Abv6ccz8wuTUUpmBlGwQcwNjSxYCuDLA4IyQ=
+github.com/redpanda-data/common-go/redpanda-otel-exporter v0.4.0 h1:lyLHsAMI4Ns8CqNDi2zuaslSNO5BHoMt+hvyoOKieII=
 github.com/redpanda-data/common-go/redpanda-otel-exporter v0.4.0/go.mod h1:kzFoUX1Abv6ccz8wuTUUpmBlGwQcwNjSxYCuDLA4IyQ=
 github.com/redpanda-data/common-go/secrets v0.1.4 h1:CGp3KolGnjcJvIafTwf7Hlj5ztLOJCjgkegRu7IAkSw=
 github.com/redpanda-data/common-go/secrets v0.1.4/go.mod h1:WjUU/5saSXwItZx6veFOGbQZUgPQz4MQ65z22y0Ky84=
diff --git a/internal/impl/otlp/attr_test.go b/internal/impl/otlp/attr_test.go
@@ -12,7 +12,7 @@
 package otlp_test
 
 import (
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 func attrMap(attrs []*pb.KeyValue) map[string]*pb.AnyValue {
diff --git a/internal/impl/otlp/input_grpc.go b/internal/impl/otlp/input_grpc.go
@@ -26,7 +26,7 @@ import (
 	"google.golang.org/grpc/metadata"
 	"google.golang.org/grpc/status"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 
 	"github.com/redpanda-data/benthos/v4/public/service"
 	"github.com/redpanda-data/benthos/v4/public/utils/netutil"
diff --git a/internal/impl/otlp/input_http.go b/internal/impl/otlp/input_http.go
@@ -25,9 +25,10 @@ import (
 	"go.opentelemetry.io/collector/pdata/pmetric/pmetricotlp"
 	"go.opentelemetry.io/collector/pdata/ptrace/ptraceotlp"
 
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
+
 	"github.com/redpanda-data/benthos/v4/public/service"
 	"github.com/redpanda-data/benthos/v4/public/utils/netutil"
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
 	"github.com/redpanda-data/connect/v4/internal/gateway"
 	"github.com/redpanda-data/connect/v4/internal/impl/otlp/otlpconv"
 	"github.com/redpanda-data/connect/v4/internal/license"
diff --git a/internal/impl/otlp/input_test.go b/internal/impl/otlp/input_test.go
@@ -37,9 +37,10 @@ import (
 	"go.opentelemetry.io/otel/trace"
 	"google.golang.org/protobuf/proto"
 
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
+
 	"github.com/redpanda-data/benthos/v4/public/service"
 	"github.com/redpanda-data/benthos/v4/public/service/integration"
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
 	"github.com/redpanda-data/connect/v4/internal/impl/otlp"
 	"github.com/redpanda-data/connect/v4/internal/license"
 )
diff --git a/internal/impl/otlp/otlpconv/conv.go b/internal/impl/otlp/otlpconv/conv.go
@@ -21,7 +21,7 @@ import (
 
 	"go.opentelemetry.io/collector/pdata/pcommon"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 // int64ToUint64 safely converts an int64 timestamp to uint64.
diff --git a/internal/impl/otlp/otlpconv/conv_test.go b/internal/impl/otlp/otlpconv/conv_test.go
@@ -18,7 +18,7 @@ import (
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/collector/pdata/pcommon"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 func TestAnyValueRoundtrip(t *testing.T) {
diff --git a/internal/impl/otlp/otlpconv/export_test.go b/internal/impl/otlp/otlpconv/export_test.go
@@ -16,7 +16,7 @@ import (
 	"go.opentelemetry.io/collector/pdata/pmetric/pmetricotlp"
 	"go.opentelemetry.io/collector/pdata/ptrace/ptraceotlp"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 // LogsToRedpanda converts OTLP log export request to individual Redpanda log
diff --git a/internal/impl/otlp/otlpconv/log.go b/internal/impl/otlp/otlpconv/log.go
@@ -16,7 +16,7 @@ import (
 	"go.opentelemetry.io/collector/pdata/plog"
 	"go.opentelemetry.io/collector/pdata/plog/plogotlp"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 // LogsCount counts the total number of log records in the request.
diff --git a/internal/impl/otlp/otlpconv/log_test.go b/internal/impl/otlp/otlpconv/log_test.go
@@ -20,7 +20,7 @@ import (
 	"go.opentelemetry.io/collector/pdata/plog"
 	"go.opentelemetry.io/collector/pdata/plog/plogotlp"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 func createTestLogs() plogotlp.ExportRequest {
diff --git a/internal/impl/otlp/otlpconv/metric.go b/internal/impl/otlp/otlpconv/metric.go
@@ -16,7 +16,7 @@ import (
 	"go.opentelemetry.io/collector/pdata/pmetric"
 	"go.opentelemetry.io/collector/pdata/pmetric/pmetricotlp"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 // MetricsCount counts the total number of metrics in the request.
diff --git a/internal/impl/otlp/otlpconv/metric_test.go b/internal/impl/otlp/otlpconv/metric_test.go
@@ -20,7 +20,7 @@ import (
 	"go.opentelemetry.io/collector/pdata/pmetric"
 	"go.opentelemetry.io/collector/pdata/pmetric/pmetricotlp"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 func createTestMetrics() pmetricotlp.ExportRequest {
diff --git a/internal/impl/otlp/otlpconv/trace.go b/internal/impl/otlp/otlpconv/trace.go
@@ -16,7 +16,7 @@ import (
 	"go.opentelemetry.io/collector/pdata/ptrace"
 	"go.opentelemetry.io/collector/pdata/ptrace/ptraceotlp"
 
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
 )
 
 // SpansCount counts the total number of spans in the request.
diff --git a/internal/impl/otlp/output_grpc.go b/internal/impl/otlp/output_grpc.go
@@ -26,9 +26,10 @@ import (
 	"google.golang.org/grpc/encoding/gzip"
 	"google.golang.org/grpc/metadata"
 
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
+
 	"github.com/redpanda-data/benthos/v4/public/service"
 	"github.com/redpanda-data/benthos/v4/public/utils/netutil"
-	"github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
 	"github.com/redpanda-data/connect/v4/internal/impl/otlp/otlpconv"
 	"github.com/redpanda-data/connect/v4/internal/license"
 	"github.com/redpanda-data/connect/v4/internal/oauth2"
@@ -312,7 +313,7 @@ func (o *grpcOTLPOutput) headersFrom(ctx context.Context, batch service.MessageB
 }
 
 func (o *grpcOTLPOutput) sendTraces(ctx context.Context, batch service.MessageBatch) error {
-	spans, err := unmarshalBatch[proto.Span](batch, "span")
+	spans, err := unmarshalBatch[pb.Span](batch, "span")
 	if err != nil {
 		return fmt.Errorf("unmarshal spans: %w", err)
 	}
@@ -336,7 +337,7 @@ func (o *grpcOTLPOutput) sendTraces(ctx context.Context, batch service.MessageBa
 }
 
 func (o *grpcOTLPOutput) sendLogs(ctx context.Context, batch service.MessageBatch) error {
-	logs, err := unmarshalBatch[proto.LogRecord](batch, "log record")
+	logs, err := unmarshalBatch[pb.LogRecord](batch, "log record")
 	if err != nil {
 		return fmt.Errorf("unmarshal logs: %w", err)
 	}
@@ -360,7 +361,7 @@ func (o *grpcOTLPOutput) sendLogs(ctx context.Context, batch service.MessageBatc
 }
 
 func (o *grpcOTLPOutput) sendMetrics(ctx context.Context, batch service.MessageBatch) error {
-	metrics, err := unmarshalBatch[proto.Metric](batch, "metric")
+	metrics, err := unmarshalBatch[pb.Metric](batch, "metric")
 	if err != nil {
 		return fmt.Errorf("unmarshal metrics: %w", err)
 	}
diff --git a/internal/impl/otlp/output_http.go b/internal/impl/otlp/output_http.go
@@ -26,9 +26,10 @@ import (
 	"go.opentelemetry.io/collector/pdata/pmetric/pmetricotlp"
 	"go.opentelemetry.io/collector/pdata/ptrace/ptraceotlp"
 
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
+
 	"github.com/redpanda-data/benthos/v4/public/service"
 	"github.com/redpanda-data/benthos/v4/public/utils/netutil"
-	"github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
 	"github.com/redpanda-data/connect/v4/internal/impl/otlp/otlpconv"
 	"github.com/redpanda-data/connect/v4/internal/license"
 	"github.com/redpanda-data/connect/v4/internal/oauth2"
@@ -375,7 +376,7 @@ func (o *httpOTLPOutput) WriteBatch(ctx context.Context, batch service.MessageBa
 }
 
 func (o *httpOTLPOutput) sendTraces(ctx context.Context, batch service.MessageBatch) error {
-	spans, err := unmarshalBatch[proto.Span](batch, "span")
+	spans, err := unmarshalBatch[pb.Span](batch, "span")
 	if err != nil {
 		return fmt.Errorf("unmarshal spans: %w", err)
 	}
@@ -389,7 +390,7 @@ func (o *httpOTLPOutput) sendTraces(ctx context.Context, batch service.MessageBa
 }
 
 func (o *httpOTLPOutput) sendLogs(ctx context.Context, batch service.MessageBatch) error {
-	logs, err := unmarshalBatch[proto.LogRecord](batch, "log record")
+	logs, err := unmarshalBatch[pb.LogRecord](batch, "log record")
 	if err != nil {
 		return fmt.Errorf("unmarshal logs: %w", err)
 	}
@@ -403,7 +404,7 @@ func (o *httpOTLPOutput) sendLogs(ctx context.Context, batch service.MessageBatc
 }
 
 func (o *httpOTLPOutput) sendMetrics(ctx context.Context, batch service.MessageBatch) error {
-	metrics, err := unmarshalBatch[proto.Metric](batch, "metric")
+	metrics, err := unmarshalBatch[pb.Metric](batch, "metric")
 	if err != nil {
 		return fmt.Errorf("unmarshal metrics: %w", err)
 	}
diff --git a/internal/impl/otlp/output_test.go b/internal/impl/otlp/output_test.go
@@ -22,9 +22,10 @@ import (
 	"github.com/stretchr/testify/require"
 	"google.golang.org/protobuf/proto"
 
+	pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"
+
 	"github.com/redpanda-data/benthos/v4/public/service"
 	"github.com/redpanda-data/benthos/v4/public/service/integration"
-	pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"
 	"github.com/redpanda-data/connect/v4/internal/impl/otlp"
 	"github.com/redpanda-data/connect/v4/internal/license"
 )

Original file line number	Diff line number	Diff line change
`@@ -12,7 +12,7 @@`
`12`	`12`	`package otlp_test`
`13`	`13`
`14`	`14`	`import (`
`15`		`- pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"`
	`15`	`+ pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"`
`16`	`16`	`)`
`17`	`17`
`18`	`18`	`func attrMap(attrs []pb.KeyValue) map[string]pb.AnyValue {`
Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@ import (`
`21`	`21`
`22`	`22`	`"go.opentelemetry.io/collector/pdata/pcommon"`
`23`	`23`
`24`		`- pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"`
	`24`	`+ pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"`
`25`	`25`	`)`
`26`	`26`
`27`	`27`	`// int64ToUint64 safely converts an int64 timestamp to uint64.`
Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ import (`
`18`	`18`	`"github.com/stretchr/testify/require"`
`19`	`19`	`"go.opentelemetry.io/collector/pdata/pcommon"`
`20`	`20`
`21`		`- pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"`
	`21`	`+ pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"`
`22`	`22`	`)`
`23`	`23`
`24`	`24`	`func TestAnyValueRoundtrip(t *testing.T) {`
Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@ import (`
`16`	`16`	`"go.opentelemetry.io/collector/pdata/pmetric/pmetricotlp"`
`17`	`17`	`"go.opentelemetry.io/collector/pdata/ptrace/ptraceotlp"`
`18`	`18`
`19`		`- pb "github.com/redpanda-data/common-go/redpanda-otel-exporter/proto"`
	`19`	`+ pb "buf.build/gen/go/redpandadata/otel/protocolbuffers/go/redpanda/otel/v1"`
`20`	`20`	`)`
`21`	`21`
`22`	`22`	`// LogsToRedpanda converts OTLP log export request to individual Redpanda log`