Skip to content

Files

Failed to load latest commit information.

Latest commit

 Cannot retrieve latest commit at this time.

History

History

forwardconnector

Forward Connector

Status
Distributions core, contrib, k8s
Issues Open issues Closed issues

Supported Pipeline Types

Exporter Pipeline Type Receiver Pipeline Type Stability Level
traces traces beta
metrics metrics beta
logs logs beta

The forward connector can merge or fork pipelines of the same type.

Configuration

If you are not already familiar with connectors, you may find it helpful to first visit the Connectors README.

The forward connector does not have any configuration settings.

receivers:
  foo:
exporters:
  bar:
connectors:
  forward:

Example Usage

Annotate distinct log streams, then merge them together, batch, and export.

receivers:
  foo/blue:
  foo/green:
processors:
  attributes/blue:
  attributes/green:
  batch:
exporters:
  bar:
connectors:
  forward:
service:
  pipelines:
    logs/blue:
      receivers: [foo/blue]
      processors: [attributes/blue]
      exporters: [forward]
    logs/green:
      receivers: [foo/green]
      processors: [attributes/green]
      exporters: [forward]
    logs:
      receivers: [forward]
      processors: [batch]
      exporters: [bar]

Preprocess data, then replicate and handle in distinct ways.

receivers:
  foo:
processors:
  resourcedetection:
  sample:
  attributes:
  batch:
exporters:
  bar/hot:
  bar/cold:
connectors:
  forward:
service:
  pipelines:
    traces:
      receivers: [foo]
      processors: [resourcedetection]
      exporters: [forward]
    traces/hot:
      receivers: [forward]
      processors: [sample, batch]
      exporters: [bar/hot]
    traces/cold:
      receivers: [forward]
      processors: [attributes]
      exporters: [bar/cold]

Add a temporary debugging exporter. (Uncomment to enable.)

receivers:
  foo:
processors:
  filter:
  batch:
exporters:
  bar:
# connectors:
#   forward:
service:
  pipelines:
    traces:
      receivers:
        - foo
      processors:
        - filter
        - batch
      exporters:
        - bar
      # - forward
  # traces/log:
  #   receivers: [forward]
  #   exporters: [debug]