diff --git a/exporter/kafkaexporter/factory.go b/exporter/kafkaexporter/factory.go index a0ed0bdc3e4b5..2614f8f8052d6 100644 --- a/exporter/kafkaexporter/factory.go +++ b/exporter/kafkaexporter/factory.go @@ -156,7 +156,7 @@ func createProfilesExporter( func exporterhelperOptions( cfg Config, - qbs exporterhelper.QueueBatchSettings, + qbs xexporterhelper.QueueBatchSettings, startFunc component.StartFunc, shutdownFunc component.ShutdownFunc, ) []exporterhelper.Option { diff --git a/exporter/kafkaexporter/partitioner.go b/exporter/kafkaexporter/partitioner.go index 7bb80d41a1428..25cde4062d175 100644 --- a/exporter/kafkaexporter/partitioner.go +++ b/exporter/kafkaexporter/partitioner.go @@ -8,7 +8,7 @@ import ( "context" "go.opentelemetry.io/collector/client" - "go.opentelemetry.io/collector/exporter/exporterhelper" + "go.opentelemetry.io/collector/exporter/exporterhelper/xexporterhelper" ) type metadataKeysPartitioner struct { @@ -17,7 +17,7 @@ type metadataKeysPartitioner struct { func (p metadataKeysPartitioner) GetKey( ctx context.Context, - _ exporterhelper.Request, + _ xexporterhelper.Request, ) string { var kb bytes.Buffer meta := client.FromContext(ctx).Metadata