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 CollectorComponent.Builder

Configuration including defaults needed to consume spans from a Pulsar topic.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
PulsarCollector	build()
PulsarCollector.Builder	clientProps(Map<String,Object> clientPropsMap)	Any properties set here will override the previous Pulsar client configuration.
PulsarCollector.Builder	concurrency(Integer concurrency)	Count of concurrent message consumers on the topic.
PulsarCollector.Builder	consumerProps(Map<String,Object> consumerPropsMap)	Any properties set here will override the previous Pulsar consumer configuration.
PulsarCollector.Builder	metrics(CollectorMetrics metrics)
PulsarCollector.Builder	sampler(CollectorSampler sampler)
PulsarCollector.Builder	serviceUrl(String serviceUrl)	The service URL for the Pulsar client ex. pulsar://my-broker:6650.
PulsarCollector.Builder	storage(StorageComponent storage)
PulsarCollector.Builder	subscriptionName(String subscriptionName)	Specify the subscription name for this consumer.
PulsarCollector.Builder	topic(String topic)	Queue zipkin spans will be consumed from.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Builder

public Builder()

Method Details

storage

public PulsarCollector.Builder storage(StorageComponent storage)

Specified by:

storage in class CollectorComponent.Builder

metrics

public PulsarCollector.Builder metrics(CollectorMetrics metrics)

Specified by:

metrics in class CollectorComponent.Builder

sampler

public PulsarCollector.Builder sampler(CollectorSampler sampler)

Specified by:

sampler in class CollectorComponent.Builder

build

public PulsarCollector build()

Specified by:

build in class 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 - Map<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 - Map<String, Object>

Returns:

Builder

See Also:

• ConsumerBuilder.loadConf(Map)