当前位置: 首页 > 知识库问答 >
问题:

获取kafka错误:低于4的MetadataRequest版本不支持allowAutoTopicCreation字段

锺英卫
2023-03-14

我使用引导版本2.1.3.RELEASE开发了Spring引导应用程序。添加了没有特定版本的Kafka客户端、Spring法夫卡、kafka_2.12和Kafka流依赖关系。应用程序旨在打开来自 kafka 主题的流,并通过在时间窗口对键进行分组来计算聚合。在调试模式下,将记录以下错误。

org.apache.kafka.common.errors网站。不支持版本异常:早于4的MetadataRequest版本不支持allowAutoTopicCreation字段

2019-10-18 09:18:05.050调试6435---[0c5acc95c admin]好的客户机管理员。KafkaAdminClient:[AdminClient clientId=CAG__CNTS_service_ads_2-d1d85a17-42e5-4d98-9ef8-ed90c5acc95c-admin]调用(callName=topicsMetadata,deadlineMs=1571370604855)失败,尝试一次后出现不可重试的异常

java.lang.Exception:不支持版本异常:MetadataRequest版本超过4不支持允许AutoTopicCreation字段org.apache.kafka.clients.admin.KafkaAdminClient$Call.fail(KafkaAdminClient.java:612)~[kafka-clients-2.0.1.jar: na]在

共有1个答案

沈建柏
2023-03-14

Boot 2.1.x(当前版本为2.1.9)使用spring-kafka 2.2.x,并且默认使用2.0.1 kafka客户端。有关兼容性矩阵,请参见项目页面。虽然您通常可以将较新的客户端与较旧的代理一起使用(从0.10开始),但是您当然只能使用代理支持的功能。

0.10. x. x对于更新的sping-kafka版本来说太旧了。

 类似资料:
  • 当我试图用proguard混淆某个应用程序时,我总是会遇到这种错误 我已经更新了Proguard并检查了项目配置文件,但总是出现相同的错误。我正在使用Intellij IDEA的最新版本

  • 我试图在所有节点都安装了Java1.7的集群上使用spark-submit运行java spark作业。 作业失败,返回java.lang.UnsupportedClassVersionError:com/WindLogics/DMF/Wether/MyClass:Unsupported Major.Minor版本51.0。 此外,当主机设置为Local时,作业也可以正常工作。如何进行调试和修复此

  • 问题内容: 在IntelliJ中,当我尝试从构建菜单进行构建时,我收到此奇怪的错误消息:错误:java:不支持版本10 我不明白,因为在“项目结构”中设置了以下设置:项目SDK:9.0项目语言级别:SDK默认模块语言级别:项目默认(两个模块) 在我的pom.xml文件中,两个模块中都设置了这些属性: 我不知道为什么要尝试将JDK 10用于任何东西,但我仍然收到该消息。我很高兴使用JDK10,但是我

  • 我刚刚安装了3.0使用在我的笔记本电脑上,这是运行14.04: 然而,当我使用时,终端似乎认为它使用的是1.2版。1: 更糟糕的是,当我去打开一个JSON nbform版本4的笔记本,它支持IPython3.0,我得到以下错误: 我试图使用团队推荐的命令将笔记本降级到版本3,但对我来说也失败了: 这到底是怎么回事?

  • 我在做 但是我已经看到了java的版本是否相等,这是正确的。 如: 哪个javac->/usr/lib/jvm/java-1.7.0-openjdk-amd64/bin/javac 哪个java->/usr/lib/jvm/java-1.7.0-openjdk-amd64/bin/java java->-version java版本“1.7.0_79”OpenJDK运行时环境(IcedTea 2.

  • 问题内容: 我有以下代码: 我正在尝试查询(例如)。 我不断收到此错误: 什么会导致此错误,我该如何解决? 问题答案: 不知道出了什么问题,但是当我尝试使用库执行相同的操作时,它会起作用: 请注意,两者之间存在差异,我的代码简单得多,它不适用于Cookie,并且不会伪装Safari浏览器。 如果您需要将Cookie与一起使用,则可以在其中找到很好的支持。