Spring Cloud Stream2.0是否兼容Kafka Broker0.10.2？

Question

那么Spring-Cloud-Stream-Binder-Kafka2.0和0.10.2代理之间是否存在兼容性问题呢？

我计划从spring-cloud-stream 1.2+Kafka 0.10.2升级到spring-cloud-stream 2.0+Kafka 1.0，并试图了解是否可以一次性完成（客户机->1.0，然后代理->1.0)，或者spring-cloud-stream支持的无停机升级路径是什么。

Answer 1

是的，它应该可以工作（我刚刚用当前快照测试了它）。

然而，2.0默认使用原生kafka头；标题是在Kafka的0.11经纪人中引入的。

您需要将生产者headermode设置为none或embeddedheaders。(none是1.x中不推荐使用的raw的同义词）。

因此，如果您希望2.0生产者为1.x使用者创建消息，无论代理版本如何，您都需要这样做。

在使用者方面，2.0将检测消息是否具有本机或嵌入的头（或没有）。

另一个警告是不能将绑定器属性AutoAddPartitions设置为true，除非代理至少是1.0.0。供应者使用javaAdminClient。1.x使用了scala客户机，它可以扩展分区。