2017-08-31 5 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'が提供されましたが、既知ではありません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)で

+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 Connectは私が実行していた環境でトピックを作成できませんでした。これらのトピックを作成することで、問題は解決しました。プロパティファイル(下記)にこれらのトピックの名前を指定していました。

offset.storage.topic

config.storage.topic

status.storage.topic

関連する問題