测试kafka升级问题2018-03-20

1.测试环境：测试是否支持回滚，升级0.10后回滚0.9.0

• 在升级好0.10.2的kafka集群中，创建测试topicdowngrade_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