1.测试环境：测试是否支持回滚，升级0.10后回滚0.9.0
-
在升级好0.10.2的kafka集群中，创建测试topic
downgrade_topic,使用producer0.9.0生产数据
image.png
image.png
-
consumer0.9.0测试消费
image.png
-
回退kafka版本，修改kafka 配置 0.10.2.0改为
image.png
重启
-
生产者测试 0.9.0.0
生产10-19 hello world -
消费者测试 0.9.0.0
image.png
-
消费者测试 0.10.2.0
image.png
结论：高版本回退为低版本（0.10.2.0 回退0.9.0.0）,
consumer0.9.0.0消费数据的话，10.2.0版本的broker保存的数据都将丢失，
consumer0.10.2.0消费数据的话，数据正常
2.测试环境：producer、consumer是否支持向前兼容(即0.10的Producer/Consumer是否支持0.9.0的broker)
-
生产者测试 0.10.2.0，生产20-29 hello world
image.png
-
消费者测试 0.10.2.0
image.png
网友评论