Re: Kafka stream error about message format

2018-04-19 Thread Guozhang Wang
Hi Shengyi, 1) Unfortunately no, see the related docs: https://kafka.apache. org/0110/documentation.html#upgrade_11_exactly_once_semantics 2) You cannot set the internal topic message format on the client side (producer, consumer, streams, ..) it is decided on the broker side only. 3) You can re

Kafka stream error about message format

2018-04-18 Thread sy.pan
Hi, All: I have upgraded my Kafka cluster from 0.10.2 to 1.1 recently. After rolling upgrade, the broker version related configuration is : inter.broker.protocol.version = 1.1 log.message.format.version = 0.10.2 I keep the log message format as low version because not all clients could upgrade