Broker Versions

Supported versions:

• 0.9.0 Default
• 0.10.0
• 0.10.1

Configuration

A Kafka broker version can be specified in the connection configuration:

let cfg = 
  KafkaConfig.create (
    host, 
    version = Versions.V_0_10_1)
let conn = Kafka.conn cfg

Currently, the default version is 0.9.0. To support later broker versions, the version must be configured explicitly as above.

Broker versions 0.10.0 and above support an ApiVersionsRequest which returns the versions supported for each operation. Kafunk can determine API versions automatically using this operation as follows:

let cfg = 
  KafkaConfig.create (
    host, 
    autoApiVersions = true)
let conn = Kafka.conn cfg

Note that this is only supported on versions 0.10.0 and greater.

Changes

See: A Guide To The Kafka Protocol

See: RELEASE NOTES

0.10.0

• Added Timestamp to Message
• Added Timestamp to ProduceResponse
• Added ApiVersionsRequest

0.10.1

• Dropped MaxNumberOfOffsets from OffsetRequest
• OffsetResponse returns a single Offset rather than array.
• Added RebalanceTimeout to JoinGroupRequest
• Search offsets by Timestamp for messages supporting the format.