Pulsar Receiver

The Pulsar Receiver receives logs, metrics, and traces from Apache Pulsar.

Status
Stability	alpha: metrics, traces, logs
Unsupported Platforms	aix
Distributions	contrib
Issues
Code coverage
Code Owners	@dao-jun
Emeritus	@dmitryax

Getting Started

The following settings can be optionally configured:

• endpoint (default = pulsar://localhost:6650): The url of pulsar cluster.
• topic (default = otlp_spans for traces, otlp_metrics for metrics, otlp_logs for logs): The name of the pulsar topic to consume from.
• encoding (default = otlp_proto): The encoding of the payload sent to pulsar. Available encodings:
  • otlp_proto: the payload is deserialized to ExportTraceServiceRequest.
  • jaeger_proto: the payload is deserialized to a single Jaeger proto Span.
  • jaeger_json: the payload is deserialized to a single Jaeger JSON Span using jsonpb.
  • zipkin_proto: the payload is deserialized into a list of Zipkin proto spans.
  • zipkin_json: the payload is deserialized into a list of Zipkin V2 JSON spans.
  • zipkin_thrift: the payload is deserialized into a list of Zipkin Thrift spans.
• consumer_name: specifies the consumer name.
• auth
  • tls
    • cert_file:
    • key_file:
  • token
    • token
  • oauth2
    • issuer_url:
    • client_id:
    • audience:
    • scope:
    • private_key: Path to the private client credentials json file. Must contain type, client_id, client_secret and issuer_url fields.
  • athenz
    • provider_domain:
    • tenant_domain:
    • tenant_service:
    • private_key:
    • key_id:
    • principal_header:
    • zts_url:
• subscription (default = otlp_subscription): the subscription name of consumer.
• tls_trust_certs_file_path: path to the CA cert. For a client this verifies the server certificate. Should only be used if insecure is set to true.
• tls_allow_insecure_connection: configure whether the Pulsar client accept untrusted TLS certificate from broker (default: false)

Example configuration:

receivers:
  pulsar:
    endpoint: pulsar://localhost:6650
    topic: otlp-spans
    subscription: otlp_spans_sub
    consumer_name: otlp_spans_sub_1
    encoding: otlp_proto
    auth:
      tls:
        cert_file: cert.pem
        key_file: key.pem
    tls_allow_insecure_connection: false
    tls_trust_certs_file_path: ca.pem