added kafkametricsreceiver (#316)

signalfx · Apr 22, 2021 · c663ba4 · c663ba4
1 parent b76a364
commit c663ba4
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 0 deletions.
diff --git a/docs/components.md b/docs/components.md
@@ -38,4 +38,5 @@ new release. In addition, any of these components may be removed prior to the
 | collectd       |            |           |            |
 | filelog        |            |           |            |
 | kafka          |            |           |            |
+| kafkametrics   |            |           |            |
 | statsd         |            |           |            |
diff --git a/go.mod b/go.mod
@@ -30,6 +30,7 @@ require (
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/filelogreceiver v0.25.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluentforwardreceiver v0.25.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver v0.25.0
+	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver v0.25.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver v0.25.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/prometheusexecreceiver v0.25.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/receivercreator v0.25.0

diff --git a/go.sum b/go.sum
@@ -1629,6 +1629,7 @@ github.com/onsi/gomega v1.10.2/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1y
 github.com/onsi/gomega v1.10.4 h1:NiTx7EEvBzu9sFOD1zORteLSt3o8gnlvZZwSE9TnY9U=
 github.com/onsi/gomega v1.10.4/go.mod h1:g/HbgYopi++010VEqkFgJHKC09uJiW9UkXvMUuKHUCQ=
 github.com/op/go-logging v0.0.0-20160315200505-970db520ece7/go.mod h1:HzydrMdWErDVzsI23lYNej1Htcns9BCg93Dk0bBINWk=
+github.com/open-telemetry/opentelemetry-collector-contrib v0.25.0 h1:Mp0umWlKgLwkhbYYYiW03DbYgv19CEdj6SdgbcBPWlM=
 github.com/open-telemetry/opentelemetry-collector-contrib/exporter/sapmexporter v0.25.0 h1:V6QtC0sB38ArVeCemfP8++o95xhvUTSeKZ7l0xj1BKs=
 github.com/open-telemetry/opentelemetry-collector-contrib/exporter/sapmexporter v0.25.0/go.mod h1:IggQ66UVuBNmOBXkt+D3L3JR2ny36mwHvFZhjGujKz4=
 github.com/open-telemetry/opentelemetry-collector-contrib/exporter/signalfxexporter v0.25.0 h1:4t6+Hz7mb8+eauPrAGKI4JVBgUpaZhJPs/r5SaZkz7I=
@@ -1675,6 +1676,8 @@ github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluentforward
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluentforwardreceiver v0.25.0/go.mod h1:GDHWSxkbSFNSfvjU6sbvM9M1KkwfmKG2a0X6WhOVKRo=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver v0.25.0 h1:LyiPTuwnmsDbokUfddjo9vFj72Pdljw1323IHFcHcbk=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver v0.25.0/go.mod h1:DhPFl3QsLnrVk10Q1rcl4Chau0tMswHcFs1yDIrA36A=
+github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver v0.25.0 h1:6u/ZIKWYaiOrTRMLGqaxEJf8GvXInDKU7KS9HP9LYZ8=
+github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver v0.25.0/go.mod h1:BZVKKoaAdPd7KtBpROUjNaix0OEbgYM47MZQbMj09ME=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver v0.25.0 h1:L60N2Vykj9YldMpJP+l3AQO97Iymqh6R5khUdGYAQhM=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver v0.25.0/go.mod h1:pKtDgKmTPYQK92II6GYOpTZWFatbe17af8q0OtnbhF4=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/prometheusexecreceiver v0.25.0 h1:OiwZEbfwxhyUSy4Flo6m1iCZRkkbH43XAvMhXd3gAuI=

diff --git a/internal/components/components.go b/internal/components/components.go
@@ -30,6 +30,7 @@ import (
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/filelogreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluentforwardreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver"
+	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/prometheusexecreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/receivercreator"
@@ -89,6 +90,7 @@ func Get() (component.Factories, error) {
 		filelogreceiver.NewFactory(),
 		jaegerreceiver.NewFactory(),
 		k8sclusterreceiver.NewFactory(),
+		kafkametricsreceiver.NewFactory(),
 		kafkareceiver.NewFactory(),
 		kubeletstatsreceiver.NewFactory(),
 		otlpreceiver.NewFactory(),

diff --git a/internal/components/components_test.go b/internal/components/components_test.go
@@ -42,6 +42,7 @@ func TestDefaultComponents(t *testing.T) {
 		"jaeger",
 		"k8s_cluster",
 		"kafka",
+		"kafkametrics",
 		"kubeletstats",
 		"otlp",
 		"prometheus",