kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dave Hamilton <dhamil...@nanigans.com>
Subject Kafka log.message.format.version and consumer client versions
Date Mon, 08 May 2017 16:33:18 GMT
Hi, I have a question about the performance implications of upgrading the Kafka message format
relating to the following from the upgrade documentation:

The message format in 0.10.0 includes a new timestamp field and uses relative offsets for
compressed messages. The on disk message format can be configured through log.message.format.version
in the server.properties file. The default on-disk message format is 0.10.0. If a consumer
client is on a version before, it only understands message formats before 0.10.0.
In this case, the broker is able to convert messages from the 0.10.0 format to an earlier
format before sending the response to the consumer on an older version. However, the broker
can't use zero-copy transfer in this case.

Would it be sufficient to upgrade all consumers to the new client version (both the Java and
Scala clients) to ensure zero-copy transfer is still used after upgrading the message version?
Or do all consumers using the Scala API need to be switched to using the new Java consumer

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message