[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'が提供されましたが、既知ではありませんconfig。 (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]警告 '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) 警告:以下の警告が検出されました:警告: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は63f02de0 @ oejsServletContextHandlerスタート{/、ヌル、AVAILABLE}(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] INFO RESTサーバーがhttp://172.28.193.126:8083/でリッスンして、広告URL http://172.28.193.126:8083/(org.apache.kafka.connect.runtime)を受信している@ 13584ms(org.eclipse.jetty.server.Server:379) [2017-08-31 10:15:21,150] .rest.RestServer:150) [2017-08-31 10:15:21,150] INFO Kafka Connect started(org.apache.kafka.connect.runtime.Connect:55) [2017-08-31 10:15: 21,468]エラーherdeの未知の例外(接続コード)を作成しようとしているときにエラーが発生しました:connect()オフセット ' at org.apache.kafka.connect.util.TopicAdmin.createTopics(TopicAdmin.java:245) at org.apache.kafka.connect.storage.KafkaOffsetBackingStore $ 1.run(KafkaOffsetBackingStore.java:99) at org .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) at org.apache.kafka.connect.runtime.AbstractHerder.startServices(AbstractHerder.java:99) at org。apache.kafka.connect.runtime.distributed.Distributed.DerributedHerder.run(DistributedHerder.java:194) at java.util.concurrent.Executors $ RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask。 (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) 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 .get(KafkaFutureImpl.java:213)org.apache.kafka.connect.util.TopicAdmin.createTopics(TopicAdmin.java:226)で
カフカ接続のどのバージョン、およびカフカのどのバージョン? Connectワーカーの設定とは何ですか? –
kafka-connect 3.3.0およびkafka 0.10.0.1 –