Package zipkin2.collector.pulsar

Class PulsarCollector.Builder

java.lang.Object
zipkin2.collector.CollectorComponent.Builder
zipkin2.collector.pulsar.PulsarCollector.Builder
Enclosing class:
PulsarCollector
public static final class PulsarCollector.Builder extends zipkin2.collector.CollectorComponent.Builder
Configuration including defaults needed to consume spans from a Pulsar topic.

  • Constructor Details

    • Builder

      public Builder()

  • Method Details

    • storage

      public PulsarCollector.Builder storage(zipkin2.storage.StorageComponent storage)
      Specified by:
      storage in class zipkin2.collector.CollectorComponent.Builder

    • metrics

      public PulsarCollector.Builder metrics(zipkin2.collector.CollectorMetrics metrics)
      Specified by:
      metrics in class zipkin2.collector.CollectorComponent.Builder

    • sampler

      public PulsarCollector.Builder sampler(zipkin2.collector.CollectorSampler sampler)
      Specified by:
      sampler in class zipkin2.collector.CollectorComponent.Builder

    • build

      public PulsarCollector build()
      Specified by:
      build in class zipkin2.collector.CollectorComponent.Builder

    • concurrency

      public PulsarCollector.Builder concurrency(Integer concurrency)
      Count of concurrent message consumers on the topic. Defaults to 1.

    • topic

      public PulsarCollector.Builder topic(String topic)
      Queue zipkin spans will be consumed from. Defaults to "zipkin".

    • serviceUrl

      public PulsarCollector.Builder serviceUrl(String serviceUrl)
      The service URL for the Pulsar client ex. pulsar://my-broker:6650. No default.

    • subscriptionName

      public PulsarCollector.Builder subscriptionName(String subscriptionName)
      Specify the subscription name for this consumer. No default.

    • clientProps

      public PulsarCollector.Builder clientProps(Map<String,Object> clientPropsMap)
      Any properties set here will override the previous Pulsar client configuration.
      Parameters:
      clientPropsMap - Mapinvalid input: '<'String, Object>
      Returns:
      Builder
      See Also:
      • ClientBuilder.loadConf(Map)

    • consumerProps

      public PulsarCollector.Builder consumerProps(Map<String,Object> consumerPropsMap)
      Any properties set here will override the previous Pulsar consumer configuration.
      Parameters:
      consumerPropsMap - Mapinvalid input: '<'String, Object>
      Returns:
      Builder
      See Also:
      • ConsumerBuilder.loadConf(Map)