[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)
什么卡夫卡连接的版本,什么版本的卡夫卡?什么是Connect工作站配置? –
kafka-connect 3.3.0和kafka 0.10.0.1 –