Options
All
  • Public
  • Public/Protected
  • All
Menu

Class KafkaClientOptions

Generic KafkaClient options.

Hierarchy

  • KafkaClientOptions

Index

Constructors

Methods

Constructors

constructor

Methods

getConfig

  • getConfig(): {}

  • Set the Kafka config.

    Returns {}

    • [key: string]: any

getTracePeerAddress

  • getTracePeerAddress(): string

  • Set the Kafka address to show in trace tags. Or leave it unset to automatically pick up bootstrap server from config instead.

    Returns string

getTracingPolicy

  • getTracingPolicy(): TracingPolicy

  • Set the Kafka tracing policy.

    Returns TracingPolicy

setConfig

  • Set the Kafka config.

    Parameters

    • config: {}
      • [key: string]: any

    Returns KafkaClientOptions

setTracePeerAddress

  • Set the Kafka address to show in trace tags. Or leave it unset to automatically pick up bootstrap server from config instead.

    Parameters

    • tracePeerAddress: string

    Returns KafkaClientOptions

setTracingPolicy

  • Set the Kafka tracing policy.

    Parameters

    • tracingPolicy: TracingPolicy

    Returns KafkaClientOptions

toJson

  • toJson(): {}

  • Returns {}

    • [key: string]: any

Generated using TypeDoc