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