CancelPulsarConsumer closes Pulsar consumer and removes from the ConsumerCache.

GetPulsarClient gets a Pulsar client object.

GetPulsarConsumer gets a Pulsar consumer object.

GetPulsarProducer gets a Pulsar producer object.

NewPulsarClient always creates a new pulsar.Client connection.

SendToPulsar sends data to a Pulsar producer.

ClientCache caches a list Pulsar clients.

ConsumerCache caches a list Pulsar prudcers key is a string concatenated with pulsar url, token, and topic full name.

ProducerCache is the cache for Producer objects.

PulsarClient encapsulates the Pulsar Client object.

PulsarConsumer encapsulates the Pulsar Consumer object.

PulsarProducer encapsulates the Pulsar Producer object.