Создайте конвейер с помощью kafka connect, используя коннекторы jdbc для sqlite - PullRequest
Новая
       9

Создайте конвейер с помощью kafka connect, используя коннекторы jdbc для sqlite

0 голосов
/ 15 мая 2018

Я новичок в kafka connect, пытаюсь построить конвейер для передачи данных из sqlite в тему kafka.

1 Ответ

0 голосов
/ 15 мая 2018

Предполагая, что ваша sqlite DB имеет значение /tmp/test.db, используйте эту конфигурацию: 

{
  "name": "jdbc-source",
  "config": {
    "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
    "tasks.max": "1",
    "connection.url": "jdbc:sqlite:/tmp/test.db",
    "mode": "incrementing",
    "incrementing.column.name": "id",
    "topic.prefix": "test-sqlite-jdbc-",
    "name": "jdbc-source"
  }
}

Для получения дополнительной информации см .:

...