Kafka Connect Microsoft SQL Server Connector не дает никакого результата - PullRequest
Новая
       91

Kafka Connect Microsoft SQL Server Connector не дает никакого результата

0 голосов
/ 05 декабря 2018

Для запуска cdc kafka connect на моем локальном компьютере с Ubuntu я запускаю его через отдельную конфигурацию Confluent.

Для Kafka Connect Microsoft SQL Server Connector,

Конфигурация, kafka-connect-mssql.json 

{
  "name" : "msSqlSourceConnector2",
  "config" : {
    "connector.class" : "io.confluent.connect.cdc.mssql.MsSqlSourceConnector",
    "tasks.max" : "1",
    "initial.database" : "MyDB",
    "username" : "SYS",
    "password" : "Mysql@123",
    "server.name" : "localhost",
    "server.port" : "1433",
    "topics": "MsSql"
  }
}

Выполнение команды ниже для запуска производителя, 

./bin/confluent load msSqlSourceConnector2 -d <path>/kafka-connect-mssql.json

Получение ниже результата, 

CLI is intended for development only, not for production
https://docs.confluent.io/current/cli/index.html

{
  "name": "msSqlSourceConnector2",
  "config": {
    "connector.class": "io.confluent.connect.cdc.mssql.MsSqlSourceConnector",
    "tasks.max": "1",
    "initial.database": "MyDB",
    "username": "SYS",
    "password": "Mysql@123",
    "server.name": "localhost",
    "server.port": "1433",
    "topics": "MsSql",
    "name": "msSqlSourceConnector2"
  },
  "tasks": [],
  "type": null
}

Когда я работаю с потребителем, онне показывает никаких результатов на этом, 

./bin/kafka-console-consumer --bootstrap-server localhost:9092 --from-beginning --property print.key=true --topic MsSql

На стороне Ms - sql, когда я делаю вставку, обновление и удаление, она фиксирует изменения в соответствующих таблицах CDC.

Дайте мне знатьесли кто-нибудь играет с этим разъемом в любое время.

...