t8y2/dbx · error

send ZooKeeper connect request: %w

Error message

send ZooKeeper connect request: %w

What it means

Returned by newProtocolZooKeeperClient when the initial ZooKeeper connection-request frame (protocol version, timeout, session id 0, password) could not be written to the socket. This is an I/O-level failure on a freshly dialed connection — closed/reset socket or write timeout — during the raw WireProtocol handshake.

Source

Thrown at agents/drivers/hive-go/zookeeper_protocol.go:156

	closed     bool
}

func newProtocolZooKeeperClient(connection net.Conn, timeout time.Duration) (*protocolZooKeeperClient, error) {
	if connection == nil {
		return nil, errors.New("ZooKeeper connection is nil")
	}
	if timeout <= 0 {
		timeout = defaultConnectTimeout
	}
	client := &protocolZooKeeperClient{connection: connection, timeout: timeout}
	request := &zooKeeperEncoder{}
	request.int32(zooKeeperProtocolVersion)
	request.int64(0)
	request.int32(zooKeeperTimeoutMillis(timeout))
	request.int64(0)
	request.bytes(make([]byte, 16))
	if err := client.writeFrame(request.data()); err != nil {
		return nil, fmt.Errorf("send ZooKeeper connect request: %w", err)
	}
	response, err := client.readFrame()
	if err != nil {
		return nil, fmt.Errorf("read ZooKeeper connect response: %w", err)
	}
	decoder := newZooKeeperDecoder(response)
	if _, err := decoder.int32(); err != nil {
		return nil, fmt.Errorf("decode ZooKeeper protocol version: %w", err)
	}
	if _, err := decoder.int32(); err != nil {
		return nil, fmt.Errorf("decode ZooKeeper session timeout: %w", err)
	}
	sessionID, err := decoder.int64()
	if err != nil {
		return nil, fmt.Errorf("decode ZooKeeper session ID: %w", err)
	}
	if _, err := decoder.bytes(); err != nil {
		return nil, fmt.Errorf("decode ZooKeeper session password: %w", err)

View on GitHub (pinned to c0390bff16)

Solutions

1. Check ZooKeeper reachability and firewall rules from the agent host
2. Confirm the ZooKeeper server did not drop the connection immediately (four-letter command stat/srvr)
3. Retry the connection; transient resets during ensemble leader election can cause this

When it happens

Trigger: Thrown at agents/drivers/hive-go/zookeeper_protocol.go:156 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of t8y2/dbx@c0390bff16 (2026-09-05). Data as JSON: /api/errors/e9fa79ac5e5aa650. Report an issue: GitHub.