kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Milind Vaidya <kava...@gmail.com>
Subject Upgrading from kafka_2.9.2-0.8.1.1 to kafka_2.11-0.10.0.0
Date Tue, 02 May 2017 18:54:58 GMT
Hi

We are required to upgrade this in out production system. We have observed
some data loss on producer side and want to try out new producer with
flush() api.

The procedure look like following as per the documents

1. Upgrade the cluster (brokers) with rolling upgrade.

2. Upgrade clients.


I have following questions regarding this procedure

1. While upgrading clients, is there any preferred order as in should
producers or consumers be updated first ?

2. What are the things that can go wrong ? Is there any recommended
rollback plan ? OR with
settings

inter.broker.protocol.version=0.8.1.1
log.message.format.version=0.8.1.1

 things will be taken care of ?

3. The consumer in this set up is Kakfa Spout from Apache Storm, any
recommendations as far as the upgrade procedure is concerned on that front ?

4. Will scala version conflict ? We are using everything java.

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