Type Alias KafkaOptions

Options for creating a Kafka client.

type KafkaOptions = {
    config: KafkaConfig;
    maxConnectionsPerBroker?: number;
    reconnect?: ReconnectStrategy;
    socketFactory: SocketFactory;
}

Index

Properties

config maxConnectionsPerBroker? reconnect? socketFactory

Properties

`Readonly`config

config: KafkaConfig

Kafka client configuration.

`Optional` `Readonly`maxConnectionsPerBroker

maxConnectionsPerBroker?: number

Maximum connections per broker (default: 1).

`Optional` `Readonly`reconnect

reconnect?: ReconnectStrategy

Opt-in reconnection strategy. When set, the pool replaces dead connections in the background with exponential backoff. Disabled by default.

`Readonly`socketFactory

socketFactory: SocketFactory

Factory function for creating runtime-specific sockets.