[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] 警告配置
已提供“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] 警告配置
已提供“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] 警告提供了配置“value.converter”
但不是已知的配置。
(org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31
10:15:20,716] 警告 已提供配置“key.converter”，但
不是已知的配置。
(org.apache.kafka.clients.admin.AdminClientConfig:231) [2017-08-31
10:15:20,768]信息码头-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.rest.resources.ConnectorsResource
包含空路径注释。警告：（子）资源方法
创建连接器在
org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource
包含空路径注释。警告：（子）资源方法
列出连接器插件
org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource
包含空路径注释。警告：（子）资源方法
服务器信息在
org.apache.kafka.connect.runtime.rest.resources.RootResource 包含
空路径注释。
[2017-08-31 10:15:21,142] 信息开始
o.e.j.s.ServletContextHandler@63f02de0{/,null,可用}
（org.eclipse.jetty.server.handler.ContextHandler：744）[2017-08-31
10:15:21,149] 信息开始
ServerConnector@61b06738{HTTP/1.1}{0.0.0.0:8083}
(org.eclipse.jetty.server.ServerConnector:266) [2017-08-31
10:15:21,149] 信息开始@13584ms
(org.eclipse.jetty.server.Server:379) [2017-08-31 10:15:21,150] 信息
REST 服务器正在监听http://172.28.193.126:8083/ http://172.28.193.126:8083/, 广告网址http://172.28.193.126:8083/ http://172.28.193.126:8083/(org.apache.kafka.connect.runtime.rest.RestServer:150) [2017-08-31
10:15:21,150] INFO Kafka Connect 启动
(org.apache.kafka.connect.runtime.Connect:55) [2017-08-31
10:15:21,468] 错误牧羊人工作线程中未捕获的异常，退出：
（org.apache.kafka.connect.runtime.distributed.DistributedHerder：206）
org.apache.kafka.connect.errors.ConnectException：错误
尝试创建/查找主题“connect-offsets”
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(Thread.java:748) 引起的：
java.util.concurrent.ExecutionException：
org.apache.kafka.common.errors.UnknownServerException：服务器
处理请求时遇到意外错误
org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
在
org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
在
org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
在
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:213)
在
org.apache.kafka.connect.util.TopicAdmin.createTopics(TopicAdmin.java:226)
当以分布式模式启动 Kafka Connect 时，它将尝试创建或期望 Kafka 中存在多个主题。就我而言，自动主题创建已关闭，因此 Kafka Connect 无法在我运行它的环境中创建主题。我自己创建这些主题解决了这个问题。您可以在属性文件（如下）中指定这些主题的名称。
offset.storage.topic
config.storage.topic
status.storage.topic
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
