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. This can allow the client to automatically determine the appropriate version to use. Currently, Kafunk does not do this and therefore, the version must be specified explicitly.

Changes

See A Guide To The Kafka Protocol

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.