尝试创建/查找主题“连接偏移”时出错

cqoc49vn  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(243)

[2017-08-31 10:15:20715]警告配置“internal.key.converter”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20715]警告配置“status.storage.replication.factor”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20715]警告配置“internal.value.converter.schemas.enable”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20715]警告配置“value.converter.schemas.enable”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20715]警告配置“internal.value.converter”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20715]警告配置“offset.storage.replication.factor”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20716]警告配置“offset.storage.topic”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20716]警告配置“value.converter”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20716]警告配置“key.converter”已提供,但不是已知配置(org.apache.kafka.clients.admin.adminclientconfig:231)[2017-08-31 10:15:20768]信息jetty-9.2.15.v20160210(org.eclipse.jetty.server。server:327)8月31日,2017 10:15:21 am org.glassfish.jersey.internal.errors logerrors警告:检测到以下警告:警告:org.apache.kafka.connect.runtime.rest.resources.connectorsresource中的(子)资源方法listconnectors包含空路径注解。警告:org.apache.kafka.connect.runtime.rest.resources.connectorsresource中的(子)资源方法createconnector包含空路径注解。警告:org.apache.kafka.connect.runtime.rest.resources.connectorPlugins资源中的(子)资源方法listconnectorplugins包含空路径注解。警告:org.apache.kafka.connect.runtime.rest.resources.rootresource中的(子)资源方法serverinfo包含空路径注解。
[2017-08-31 10:15:21142]信息开始o.e.j.s。servletcontexthandler@63f02de0{/,null,可用}(org.eclipse.jetty.server.handler.conte)xthandler:744)[2017-08-31 10:15:21149]信息开始serverconnector@61b06738{http/1.1}{0.0.0.0:8083}(org.eclipse.jetty.server.server)connector:266) [2017-08-31 10:15:21,149]信息开始于13584ms(org.eclipse.jetty.server)。server:379)[2017-08-31 10:15:21150]信息rest服务器正在侦听http://172.28.193.126:8083/,广告urlhttp://172.28.193.126:8083/(org.apache.kafka.connect.runtime.rest.r)estserver:150) [2017-08-31 10:15:21,150]信息kafka connect已启动(org.apache.kafka.connect.runtime)。connect:55)[2017-08-31 10:15:21468]herder工作线程中出现错误未捕获异常,正在退出:(org.apache.kafka.connect.runtime.distributed.distribu)tedherder:206)org.apache.kafka.connect.errors.connectexception:尝试在org.apache.kafka.connect.util.topicadmin.createtopics(topicadmin)上创建/查找主题“连接偏移量”时出错。java:245)在org.apache.kafka.connect.storage.kafkaoffsetbackingstore$1.run(kafkaoffsetbackingstore。java:99)在org.apache.kafka.connect.util.kafkabasedlog.start(kafkabasedlog。java:126)在org.apache.kafka.connect.storage.kafkaoffsetbackingstore.start(kafkaoffsetbackingstore。java:109)在org.apache.kafka.connect.runtime.worker.start(worker。java:146)在org.apache.kafka.connect.runtime.abstractherder.startservices(abstractherder。java:99)在org.apache.kafka.connect.runtime.distributed.distributedherder.run(distributedherder。java:194)在java.util.concurrent.executors$runnableadapter.call(executors。java:511)在java.util.concurrent.futuretask.run(futuretask。java:266)在java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor。java:1149)在java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor。java:624)在java.lang.thread.run(线程。java:748)原因:java.util.concurrent.executionexception:org.apache.kafka.common.errors.unknownserverexception:服务器遇到意外错误在org.apache.kafka.common.internals.kafkafutureinpl.wrapandthrow(kafkafutureinpl)中处理请求时出错。java:45)访问org.apache.kafka.common.internals.kafkafutureinpl.access$000(kafkafutureinpl。java:32)在org.apache.kafka.common.internals.kafkafutureinpl$singlewaiter.await(kafkafutureinpl。java:89)在org.apache.kafka.common.internals.kafkafutureinpl.get(kafkafutureinpl。java:213)在org.apache.kafka.connect.util.topicadmin.createtopics(topicadmin。java:226)

svmlkihl

svmlkihl1#

kafka connect 0.11.0.0无法在早于0.10.1.0的代理上创建主题,因为这些旧代理中使用的协议不支持主题管理。
因此,如果您有一个旧的代理,您应该手动创建主题或者依赖代理自动创建。不幸的是,kafka connect 0.11.0.0中的一个bug阻止了自动创建,因此在0.11.0.1可用之前,您必须手动创建主题。

kx5bkwkv

kx5bkwkv2#

在分布式模式下启动kafka connect时,它将尝试创建或期望kafka中出现多个主题。在我的例子中,自动主题创建已关闭,因此kafka connect无法在我运行它的环境中创建主题。我自己创建这些主题解决了这个问题。您应该在您的属性文件(下面)中指定这些主题的名称。 offset.storage.topic config.storage.topic status.storage.topic

相关问题