私はCamusからKafka Connectへの移行に取り組んでいます。私はKafka Connectの実装に取り組んでおり、具体的には分散モードに焦点を当てています。私は私のカフカクラスターと通信している私のローカルマシン上で正常に作業者を開始することができます。私はさらに、正しいJSONを返す/と/connector-pluginsのような2つのGETコマンドを実行することができます。しかし、コネクタを作成するコマンドをPOSTしようとすると、500エラーとタイムアウトが発生します。Kafka Connectでコネクタを作成する分散エラーが返る500エラー
curl -X POST -H "Content-Type: application/json" --data '{"name": "local-file-sink", "config": {"connector.class":"FileStreamSinkConnector", "tasks.max":"1", "file":"test.sink.txt", "topics":"myTopic" }}' localhost:8083/connectors
を、最終的に私はこの応答を得る：具体的には、私はテストのためにPOSTには、このコマンドを使用し
{"error_code": 500, "message": "Request timed out"}
私は何が起こっているかのよう失っています。私のKafka Connect分散作業員のログには、次のように表示されます。
[2016-12-05 14:34:32,436] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:22:34:32 +0000] "GET /connector-plugins HTTP/1.1" 200 315 2 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:05:25,422] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:05:25 +0000] "GET /connector-plugins HTTP/1.1" 200 315 3 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:05:28,389] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:05:28 +0000] "GET /connector-plugins HTTP/1.1" 200 315 2 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:07:38,644] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:06:08 +0000] "GET /connectors HTTP/1.1" 500 48 90003 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:07:44,450] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:07:44 +0000] "GET /connector-plugins HTTP/1.1" 200 315 1 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:13:06,703] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:11:36 +0000] "POST /connectors HTTP/1.1" 500 48 90003 (org.apache.kafka.connect.runtime.rest.RestServer:60)
[2016-12-05 15:15:38,506] INFO 0:0:0:0:0:0:0:1 - - [05/Dec/2016:23:14:08 +0000] "POST /connectors HTTP/1.1" 500 48 90005 (org.apache.kafka.connect.runtime.rest.RestServer:60)
エラーコードとコマンドが表示されます。
私は私のメインの質問を推測し、問題点は以下のとおりです。
- にはどうすればカフカConnectには、私はより良いデバッグを試すことができますし、この問題を解決することができますか？
- 私がやっていることは、はっきりと間違っていますか？
- Kafka Connect分散ワーカーとコネクタを稼働させるためのステップバイステップのドキュメントやブログ記事はありますか？私は実際に何か、またはベストプラクティスの種類のドキュメントを見たことがありませんか？たぶん私はアダプターの早すぎるのです。
私はコミュニティからのご返信をお待ちしております、ありがとうございます！
ブローカクラスタにブローカが存在するかどうかを確認するには、 'broker.id = 0' –