@qualithm/kafka-client - v0.1.6
    Preparing search index...

    Function discoverBrokers

    • Discover all brokers in a Kafka cluster using the Metadata API.

      Connects to one of the bootstrap brokers, sends an ApiVersions request to negotiate the Metadata API version, then sends a Metadata request with an empty topic list (broker discovery only).

      Parameters

      • bootstrap: readonly BrokerAddress[]

        Bootstrap broker addresses to try.

      • socketFactory: SocketFactory

        Factory for creating sockets.

      • Optionaloptions: {
            clientId?: string;
            connectTimeoutMs?: number;
            requestTimeoutMs?: number;
            sasl?: SaslConfig;
            tls?: TlsConfig;
        }

        Optional connection settings.

      Returns Promise<readonly BrokerInfo[]>

      Array of discovered brokers.

      If no bootstrap broker is reachable.