Fix some typo in kafkareceiver and kafkaexporter package (open-teleme…

…try#2955)
punya · Apr 19, 2021 · a7f9784 · a7f9784
1 parent ec395ec
commit a7f9784
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/factory.go b/factory.go
@@ -41,7 +41,7 @@ const (
 	defaultMetadataFull = true
 )
 
-// FactoryOption applies changes to kafkaExporterFactory.
+// FactoryOption applies changes to kafkaReceiverFactory.
 type FactoryOption func(factory *kafkaReceiverFactory)
 
 // WithAddUnmarshallers adds marshallers.

diff --git a/factory_test.go b/factory_test.go
@@ -68,15 +68,15 @@ func TestWithUnmarshallers(t *testing.T) {
 
 	t.Run("custom_encoding", func(t *testing.T) {
 		cfg.Encoding = unmarshaller.Encoding()
-		exporter, err := f.CreateTracesReceiver(context.Background(), component.ReceiverCreateParams{}, cfg, nil)
+		receiver, err := f.CreateTracesReceiver(context.Background(), component.ReceiverCreateParams{}, cfg, nil)
 		require.NoError(t, err)
-		require.NotNil(t, exporter)
+		require.NotNil(t, receiver)
 	})
 	t.Run("default_encoding", func(t *testing.T) {
 		cfg.Encoding = new(otlpTracesPbUnmarshaller).Encoding()
-		exporter, err := f.CreateTracesReceiver(context.Background(), component.ReceiverCreateParams{}, cfg, nil)
+		receiver, err := f.CreateTracesReceiver(context.Background(), component.ReceiverCreateParams{}, cfg, nil)
 		require.NoError(t, err)
-		assert.NotNil(t, exporter)
+		assert.NotNil(t, receiver)
 	})
 }
 

diff --git a/kafka_receiver_test.go b/kafka_receiver_test.go
@@ -57,7 +57,7 @@ func TestNewReceiver_encoding_err(t *testing.T) {
 	assert.EqualError(t, err, errUnrecognizedEncoding.Error())
 }
 
-func TestNewExporter_err_auth_type(t *testing.T) {
+func TestNewReceiver_err_auth_type(t *testing.T) {
 	c := Config{
 		ProtocolVersion: "2.0.0",
 		Authentication: kafkaexporter.Authentication{