我使用的是最新的Greenwich.SR1,包括spring云流(version: Fishtown.SR2)和本地启动的kafka客户端版本:2.2.0,使用kafka_2.12-2.2.0.jar
我想使用最新的kafka客户端2.1或更高版本的spring云流,因为它包含一些重要的bug修复。但是当我运行我的spring应用程序时,它的日志上写着
INFO 37812 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 2.0.1如何与最新的kafka客户端一起使用spring云流?我想使用max.task.idle.ms的最新StreamsConfig卡夫卡客户端,但它似乎是最新的春季云流卡夫卡流绑定,不是支持卡夫卡客户端2.1.0或更高版本?
发布于 2019-05-21 13:34:34
Spring版本控制规则不允许我们在点版本中升级到kafka客户端的新版本。因为Fishtown对于Apache 2.2使用Spring,所以它使用了2.0.xKafka-客户端。
Apache下一个版本的将使用2.2.0客户机(或者2.3.0 (如果到那时可用),因此下一个版本的绑定器将基于较新的客户端。
当kafka-客户端被覆盖时,消息通道绑定可以工作,但不幸的是,流绑定并不是由于某些内部API更改造成的。
https://stackoverflow.com/questions/56231946
复制相似问题