我使用BootVersion2.1.3.release开发了SpringBoot应用程序。添加了kafka客户端、spring fafka、kafkaèu 2.12和kafka streams依赖项,但没有特定版本。该应用程序旨在打开来自Kafka主题的流,并通过在时间点对键进行分组来进行计数聚合。在调试模式下,会记录以下错误。
org.apache.kafka.common.errors.unsupportedversionexception:早于4的metadatarequest版本不支持allowautotopiccreation字段
2019-10-18 09:18:05.050 debug 6435---[0c5acc95c admin]o.a.k.clients.admin.kafkaadminclient:[adminclient clientid=cag\U cnts\U service\U ads\U 2-d1d85a17-42e5-4d98-9ef8-ed90c5acc95c-admin]调用(callname=topicsmetadata,deadlinems=1571370604855)失败,尝试1次后出现不可检索的异常
java.lang.exception:unsupportedversionexception:早于4的metadatarequest版本不支持org.apache.kafka.clients.admin.kafkaadminclient$call.fail(kafkaadminclient)中的allowautotopiccreation字段。java:612)~[kafka-clients-2.0.1。jar:na]在>org.apache.kafka.clients.admin.kafkaadminclient$adminclientrunnable.handleresponses(kafkaadminclient)。java:984)[Kafka客户机-2.0.1。jar:na]在>org.apache.kafka.clients.admin.kafkaadminclient$adminclientrunnable.run(kafkaadminclient。java:1124)[Kafka客户机-2.0.1。jar:na]在java.lang.thread.run(线程。java:748)[na:1.8.0_]
1条答案
按热度按时间knsnq2tg1#
boot2.1.x(当前版本是2.1.9)使用springkafka2.2.x,默认情况下使用2.0.1kafka客户机。有关兼容性矩阵,请参见项目页面。虽然您通常可以将较新的客户机与较旧的代理一起使用(自0.10以来),但您当然只能使用代理支持的功能。
对于较新的SpringKafka版本来说,0.10.x.x实在太旧了。