установить коннектор к кафке коннект с помощью rest API - PullRequest
Новая
       5

установить коннектор к кафке коннект с помощью rest API

0 голосов
/ 20 января 2020

Я хочу добавить соединитель в мой локальный кластер Kafka, используя apache Kafka Connect Rest API. Вы знаете какой-нибудь пример, чтобы сделать это, пожалуйста. Спасибо

1 Ответ

1 голос
/ 20 января 2020

Документация Confluent включает в себя наглядный пример того, как добавить Соединитель через Kafka REST API:

POST /connectors

Создайте новый соединитель, возвращая информацию о текущем соединителе в случае успеха.

Возврат 409 (конфликт), если происходит перебалансировка.

Пример запроса: 

POST /connectors HTTP/1.1
Host: connect.example.com
Content-Type: application/json
Accept: application/json

{
    "name": "hdfs-sink-connector",
    "config": {
        "connector.class": "io.confluent.connect.hdfs.HdfsSinkConnector",
        "tasks.max": "10",
        "topics": "test-topic",
        "hdfs.url": "hdfs://fakehost:9000",
        "hadoop.conf.dir": "/opt/hadoop/conf",
        "hadoop.home": "/opt/hadoop",
        "flush.size": "100",
        "rotate.interval.ms": "1000"
    }
}

Пример ответа: 

HTTP/1.1 201 Created
Content-Type: application/json

{
    "name": "hdfs-sink-connector",
    "config": {
        "connector.class": "io.confluent.connect.hdfs.HdfsSinkConnector",
        "tasks.max": "10",
        "topics": "test-topic",
        "hdfs.url": "hdfs://fakehost:9000",
        "hadoop.conf.dir": "/opt/hadoop/conf",
        "hadoop.home": "/opt/hadoop",
        "flush.size": "100",
        "rotate.interval.ms": "1000"
    },
    "tasks": [
        { "connector": "hdfs-sink-connector", "task": 1 },
        { "connector": "hdfs-sink-connector", "task": 2 },
        { "connector": "hdfs-sink-connector", "task": 3 }
    ]
}
GET /
...