Example Analysis of compatibility between librdkafka and Broker versions

This article shows you the example analysis of the compatibility of librdkafka and Broker versions, which is concise and easy to understand, which will definitely brighten your eyes. I hope you can get something through the detailed introduction of this article.

Since the release of version 0.8.0.0.0, librdkafka supports all released versions of Apache Kafka broker, but not all syntax attributes are accepted by broker because

Some syntax features depend on the specific implementation of broker

Current default configuration:

Api.version.request=true

Broker.version.fallback=0.9.0.0

Api.version.fallback.ms=0 (never revert to broker.version.fallback)

Configure librdkafka specifically according to the version of broker used in the field

Broker version > = 0.10.0.0 (or trunk)

You no longer need to configure api.version related parameters for librdkafka > = v1.0.0

For librdkafka < v1.0.0, you need to specify the following configuration:

Api.version.request=true

Api.version.fallback.ms=0

Broker versions 0.9.0.x

Api.version.request=false

Broker.version.fallback=0.9.0.x (the exact 0.9.0. Version you are using)

Broker versions 0.8.x.y

Api.version.request=false

Broker.version.fallback=0.8.x.y (your exact 0.8... Broker version)

Detailed description

Apache Kafka supports KIP-35 in version 0.10.0.0 (provides the required type and supported version of the API function query)

(allows the client to query which operations are legal), it is impossible to know whether the old version of broker supports it or not.

The above is a sample analysis of compatibility between librdkafka and Broker versions. Have you learned any knowledge or skills? If you want to learn more skills or enrich your knowledge reserve, you are welcome to follow the industry information channel.