A connected socket to a Kafka broker.
Runtime adapters wrap their native socket types to implement this interface. Data arrives via the SocketConnectOptions.onData callback provided at connection time; this type only exposes write and close operations.
Readonly
Close the connection gracefully.
Send raw bytes to the broker. Resolves when the data is flushed.
A connected socket to a Kafka broker.
Runtime adapters wrap their native socket types to implement this interface. Data arrives via the SocketConnectOptions.onData callback provided at connection time; this type only exposes write and close operations.