Pulsar.ServiceDiscovery (Pulsar v2.8.13)

Copy Markdown View Source

This module handles topic lookup operations that discover which broker owns a particular topic. The lookup process may involve following redirects across multiple brokers in a cluster before finding the authoritative broker for a topic.

Example

{:ok, broker_pid} = Pulsar.ServiceDiscovery.lookup_topic("persistent://public/default/my-topic")

Summary

Functions

lookup_topic(topic, opts \\ [])

Functions

lookup_topic(topic, opts \\ [])

@spec lookup_topic(
  String.t(),
  keyword()
) :: {:ok, pid()} | {:error, any()}