2017-08-31 29 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

相關問題