CDH5.16.1升级kafka0.10到1.0.1

 

 

激活1.0.1的包

 

 

 

然后重启各个节点

 

 

 

 

 

检查kafka版本是否升级成功

 

 

 

 

 

版本升级成功

 

 

 

 

 

验证之前的topic是否可用

 

生产者启动 

[cloudera-scm@cdh4 parcel-repo]$ /opt/cloudera/parcels/KAFKA-2.1.1-1.2.1.1.p0.18/lib/kafka/bin/kafka-console-producer.sh --broker-list cdh1:9092,cdh2:9092,cdh3:9092 --topic test

 

 

 

消费者启动 没有问题，完美兼容 

[cloudera-scm@cdh4 ~]$ /opt/cloudera/parcels/KAFKA-2.1.1-1.2.1.1.p0.18/lib/kafka/bin/kafka-console-consumer.sh -zookeeper cdh1,cdh2,cdh3:2181 --from-beginning --topic test