KafkaConfig

Namespace: Kafunk

Kafka connection configuration.

Record Field	Description
`autoApiVersions` Signature: bool	Indicates whether API versions are automatically determined based on the ApiVersionsResponse.
`bootstrapConnectRetryPolicy` Signature: RetryPolicy	The retry policy for connecting to bootstrap brokers.
`bootstrapServers` Signature: Uri list	The bootstrap brokers to attempt connection to.
`clientId` Signature: ClientId	A logical application name to pass to the server along with requests. The purpose of this is to be able to track the source of requests beyond just ip/port.
`connId` Signature: string	A unique connection id.
`requestRetryPolicy` Signature: RetryPolicy	The retry policy for broker requests.
`tcpConfig` Signature: ChanConfig	TCP connection configuration.
`version` Signature: Version	The Kafka server version.

Static member	Description
`create(...)` Signature: (bootstrapServers:Uri list * clientId:ClientId option * tcpConfig:ChanConfig option * bootstrapConnectRetryPolicy:RetryPolicy option * requestRetryPolicy:RetryPolicy option * version:Version option * autoApiVersions:bool option) -> KafkaConfig	Creates a Kafka configuration object.
`DefaultAutoApiVersions` Signature: bool	The default setting for supporting auto API versions = false. CompiledName: `get_DefaultAutoApiVersions`
`DefaultBootstrapConnectRetryPolicy` Signature: RetryPolicy	The default bootstrap broker connection retry policy = RetryPolicy.constantBoundedMs 2000 3. CompiledName: `get_DefaultBootstrapConnectRetryPolicy`
`DefaultChanConfig` Signature: ChanConfig	The default broker channel configuration. CompiledName: `get_DefaultChanConfig`
`DefaultClientId` Signature: string	The default client id = "". CompiledName: `get_DefaultClientId`
`DefaultRequestRetryPolicy` Signature: RetryPolicy	The default request retry policy = RetryPolicy.expRandLimitBoundedMs 100 1.5 0.2 1000 2. CompiledName: `get_DefaultRequestRetryPolicy`
`DefaultVersion` Signature: Version	The default Kafka server version = 0.10.1. CompiledName: `get_DefaultVersion`