Struct KafkaDiscovery 

pub struct KafkaDiscovery { /* private fields */ }

Kafka-based node discovery.

Uses the Kafka consumer group protocol for membership management. When Kafka is already deployed, this provides discovery without additional infrastructure (no separate gossip or etcd needed).

Implementations

impl KafkaDiscovery

pub fn new(config: KafkaDiscoveryConfig) -> Self

Create a new Kafka discovery instance.

pub fn discovery_topic(&self) -> &str

Get the discovery topic name.

pub fn group_id(&self) -> &str

Get the group ID.

pub fn local_node_info(&self) -> NodeInfo

Build a NodeInfo for this node.

pub fn process_heartbeat(&self, info: NodeInfo) -> bool

Process a received heartbeat message from another node.

Returns true if this is a new node (join event).

pub fn check_liveness(&self)

Check for nodes that have missed heartbeats and update their state.

pub fn serialize_heartbeat(info: &NodeInfo) -> (String, String)

Serialize a NodeInfo to a JSON message key and value.

pub fn deserialize_heartbeat(value: &str) -> Option<NodeInfo>

Deserialize a heartbeat message.

Trait Implementations

impl Debug for KafkaDiscovery

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Discovery for KafkaDiscovery

async fn start(&mut self) -> Result<(), DiscoveryError>

Start the discovery service.

async fn peers(&self) -> Result<Vec<NodeInfo>, DiscoveryError>

Get the current set of known peers (excluding self).

async fn announce(&self, info: NodeInfo) -> Result<(), DiscoveryError>

Announce this node’s updated information to the cluster.

fn membership_watch(&self) -> Receiver<Vec<NodeInfo>>

Subscribe to membership change events.

async fn stop(&mut self) -> Result<(), DiscoveryError>

Gracefully stop the discovery service.