Module discovery 

Kafka-based discovery for delta nodes.

Uses Kafka consumer group protocol for node discovery and membership. Each node joins a shared consumer group; the group coordinator handles membership, heartbeats, and rebalancing. This provides zero-infrastructure discovery when Kafka is already deployed.

How It Works

1. Each node creates a Kafka consumer in a shared group (the “discovery group”).
2. Node metadata is published to a dedicated Kafka topic as keyed messages.
3. A background task polls the topic for membership changes.
4. Consumer group rebalance callbacks detect join/leave events.

Key Format

Topic: _laminardb_discovery (configurable) Key: node:{node_id} Value: JSON-serialized NodeInfo

Structs

KafkaDiscovery

Kafka-based node discovery.

KafkaDiscoveryConfig

Configuration for Kafka-based discovery.

LaminarPartitionAssignor

Custom partition assignor for LaminarDB delta.