pulsar

logs
 

Collect observability events from Apache Pulsar topics.

Example

# The endpoint to which the Pulsar client should connect to.
#
# Optional
endpoint: pulsar://127.0.0.1:6650

# The Pulsar topic names to read events from
#
# Optional
topics: []

# The Pulsar consumer name.
#
# Optional
consumer_name: null

# The Pulsar subscription name.
#
# Optional
subscription_name: null

# The consumer's priority level
# 
# The broker follows descending priorities. For example, 0=max-priority, 1, 2...
# 
# In shared subscription type, the broker first dispatches messages to the max
# priority level consumers if they have permits. Otherwise, the broker considers
# next priority level consumers.
#
# Optional
priority_level: null

# Max count of messages in a batch
#
# Optional
batch_size: null

# Authentication configuration
#
# Optional
auth: 
  # Basic authentication name/username
  # 
  # This can be used either for basic authentication(username/password) or
  # JWT authentication. When used for JWT, the value should be `token`.
  #
  # Optional
  name: ""

  # Basic authentication password/token
  # 
  # This can be used either for basic authentication (username/password) or
  # JWT authentication. When used for JWT, the value should be the signed
  # JWT, in the compact representation.
  #
  # Optional
  token: ""

# Dead Letter Queue Policy configuration
#
# Optional
dead_letter_queue_policy: 
  # Maximum number of times that a message will be redelivered before being
  # sent to the dead letter queue.
  #
  # Optional
  max_redeliver: 1

  # Name of the dead letter topic where the failing messages will be sent
  #
  # Optional
  dead_letter_topic: ""

# Configuration for building a `Framer`.
#
# Optional
framing: bytes

# Configuration for building a `Deserializer`.
#
# Optional
decoding: 
  codec: json

  # Determines whether or not to replace invalid UTF-8 sequences instead of failing.
  # 
  # When true, invalid UTF-8 sequences are replaced with the [`U+FFFD REPLACEMENT CHARACTER`][U+FFFD].
  # 
  # [U+FFFD]: https://en.wikipedia.org/wiki/Specials_(Unicode_block)#Replacement_character
  #
  # Optional
  lossy: true

tls: 
  # File path containing a list of PEM encoded certificates
  #
  # Optional
  ca: ""

  # Enables certificate verification
  # 
  # Do not set theis to `false` unless you understand the risks of
  # not verifying the validity of certificates.
  #
  # Optional
  verify_certificate: true

  # Whether hostname verification is enabled when verify_certificate is false
  # 
  # Set to true if not specified
  #
  # Optional
  verify_hostname: true