Broker Versions

Supported versions:

• 0.9.0 Default
• 0.10.0
• 0.10.1

---

NOTE: Later broker versions work with earlier versions of the client. However, earlier versions of the client may not have support for particular features of the API. For example, client versions prior to v0.10.0 don't support Message Timestamps. Moreover, when using a newer broker version with an older client, the broker has to do additional work to adapt the message format.

---

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.