diff --git a/cmd/opentelemetry-collector/app/receiver/kafka/flags.go b/cmd/opentelemetry-collector/app/receiver/kafka/flags.go new file mode 100644 index 00000000000..ed5056d35e2 --- /dev/null +++ b/cmd/opentelemetry-collector/app/receiver/kafka/flags.go @@ -0,0 +1,26 @@ +// Copyright (c) 2020 The Jaeger Authors. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package kafka + +import ( + "flag" + + ingesterApp "github.com/jaegertracing/jaeger/cmd/ingester/app" +) + +// AddFlags adds Ingester flags. +func AddFlags(flags *flag.FlagSet) { + ingesterApp.AddFlags(flags) +} diff --git a/cmd/opentelemetry-collector/cmd/ingester/main.go b/cmd/opentelemetry-collector/cmd/ingester/main.go index 2729ac71ace..87e758ca3ad 100644 --- a/cmd/opentelemetry-collector/cmd/ingester/main.go +++ b/cmd/opentelemetry-collector/cmd/ingester/main.go @@ -28,6 +28,7 @@ import ( jflags "github.com/jaegertracing/jaeger/cmd/flags" "github.com/jaegertracing/jaeger/cmd/opentelemetry-collector/app" "github.com/jaegertracing/jaeger/cmd/opentelemetry-collector/app/defaults" + "github.com/jaegertracing/jaeger/cmd/opentelemetry-collector/app/receiver/kafka" jconfig "github.com/jaegertracing/jaeger/pkg/config" "github.com/jaegertracing/jaeger/pkg/version" "github.com/jaegertracing/jaeger/plugin/storage" @@ -91,6 +92,7 @@ func main() { cmd := svc.Command() jconfig.AddFlags(v, cmd, + kafka.AddFlags, app.AddComponentFlags, storageFlags, )