2017-08-31 128 views
0

[2017-08-31 10:15:20,715] WARN提供了配置'internal.key.converter'但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,715] WARN提供了配置'status.storage.replication.factor',但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,715] WARN提供配置'internal.value.converter.schemas.enable',但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,715] WARN提供了配置'value.converter.schemas.enable',但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,715] WARN提供了配置'internal.value.converter',但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,715] WARN提供了配置'offset.storage.replication.factor',但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,716] WARN配置'offset.storage.topic'被提供,但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,716] WARN提供了配置'value.converter',但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,716] WARN提供了配置'key.converter',但不是已知的配置。 (org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31 10:15:20,768] INFO jetty-9.2.15.v20160210(org.eclipse.jetty.server.Server:327) 2017年8月31日上午10:15:21 org.glassfish.jersey.internal.Errors logErrors 警告:已检测到以下警告:警告:org.apache.kafka.connect.runtime中的(子)资源方法listConnectors。 rest.resources.ConnectorsResource包含空路径注释。 警告:org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource中的(子)资源方法createConnector包含空路径注释。 警告:org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource中的(子)资源方法listConnectorPlugins包含空路径注释。 警告:org.apache.kafka.connect.runtime.rest.resources.RootResource中的(子)资源方法serverInfo包含空路径注释。无法在分布模式下运行Kafka Connect - 尝试创建/查找主题'连接偏移'时出错

[2017年8月31日10:15:21142] INFO发起者oejsServletContextHandler @ 63f02de0 {/,NULL,AVAILABLE}(org.eclipse.jetty.server.handler.ContextHandler:744) [2017-08- 31 10:15:21149] INFO发起者ServerConnector @ 61b06738 {HTTP/1.1} {0.0.0.0:8083}(org.eclipse.jetty.server.ServerConnector:266) [2017年8月31日10:15:21149] INFO入门@ 13584ms(org.eclipse.jetty.server.Server:379) [2017年8月31日10:15:21150] INFO REST服务器在http://172.28.193.126:8083/听,广告URL http://172.28.193.126:8083/(org.apache.kafka.connect.runtime .rest.RestServer:150) [2017-08-31 10:15:21,150]信息Kafka Connect开始(org.apache.kafka.connect.runtime.Connect:55) [2017-08-31 10:15: 21,468]错误在草地上未捕获的异常[R工作线程,退出:(org.apache.kafka.connect.runtime.distributed.DistributedHerder:206) org.apache.kafka.connect.errors.ConnectException:错误尝试创建/找到主题(S)“连接 - 在偏移org.apache.kafka.connect.util.TopicAdmin.createTopics (TopicAdmin.java:245) 在org.apache.kafka.connect.storage.KafkaOffsetBackingStore $ 1.run(KafkaOffsetBackingStore.java:99) 在组织.apache.kafka.connect.util.KafkaBasedLog.start(KafkaBasedLog.java:126) at org.apache.kafka.connect.storage.KafkaOffsetBackingStore.start(KafkaOffsetBackingStore.java:109) at org.apache.kafka.connect .runtime.Worker.start(Worker.java:146) 在org.apache.kafka.connect.runtime.AbstractHerder.startServices(AbstractHerder.java:99) 的组织。apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:194) at java.util.concurrent.Executors $ RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask。在java中运行java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor.java:624) 。 lang.Thread.run(Thread.java:748) 引起:java.util.concurrent.ExecutionException:org.apache.kafka.common.errors.UnknownServerException:在org处理请求 时,服务器遇到意外错误。 apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45) at org.apache.kafka.common.internal s.KafkaFutureImpl.access $ 000(KafkaFutureImpl.java:32) at org.apache.kafka.common.internals.KafkaFutureImpl $ SingleWaiter.await(KafkaFutureImpl.java:89) at org.apache.kafka.common.internals.KafkaFutureImpl获得(KafkaFutureImpl.java:213) 在org.apache.kafka.connect.util.TopicAdmin.createTopics(TopicAdmin.java:226)

+0

什么卡夫卡连接的版本,什么版本的卡夫卡?什么是Connect工作站配置? –

+0

kafka-connect 3.3.0和kafka 0.10.0.1 –

回答

1

卡夫卡连接0.11.0.0不能创造出比0.10更年长的经纪人的主题。 1.0,因为那些老经纪人使用的协议不支持话题管理。

因此,如果您有一个较老的代理,您应该手动创建主题或依靠代理自动创建。不幸的是,Kafka Connect 0.11.0.0中的a bug会阻止自动创建,所以在0.11.0.1可用之前,您将不得不手动创建主题。

0

当以分布式模式启动Kafka Connect时,它会尝试创建或期望在Kafka中出现几个主题。在我的情况下,自动创建主题已关闭,所以Kafka Connect无法在我运行它的环境中创建主题。创建这些主题我自己解决了问题。您应该在属性文件中指定这些主题的名称(如下所示)。

offset.storage.topic

config.storage.topic

status.storage.topic

相关问题