Azure SQL Database connector

Hello all,
I am using Azure SQL Data Warehouse Sink Connector for Confluent Platform.

I am using Azure SQL emulator for testing
Here is connector config

       "name": "sqlserver-sink-azure-connector",
       "connector.class": "io.confluent.connect.azuresqldw.AzureSqlDwSinkConnector",
       "value.converter": "org.apache.kafka.connect.json.JsonConverter",
       "value.converter.schemas.enable": "true",
       "key.converter": "",
       "key.converter.schemas.enable": "false",
       "transforms": "RenameFields",
       "transforms.RenameFields.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
       "transforms.RenameFields.renames": "Email:vchEmail,Login:vchLogin,Name:vchName,Password:vchPassword",
       "topics": "new_user",
       "azure.sql.dw.url": "jdbc:sqlserver://;",
       "azure.sql.dw.user": "sa",
       "azure.sql.dw.password": "xxx#",
       "": "xxx",
       "insert.mode": "insert",
       "auto.create": "true",
       "auto.evolve": "true",
       "tasks.max": "1",
       "confluent.topic.bootstrap.servers": "broker:29092"

I have produce below message in topic

	"schema": {
		"type": "struct",
		"fields": [{
			"type": "string",
			"optional": false,
			"field": "Email"
			"type": "string",
			"optional": false,
			"field": "Login"
			"type": "string",
			"optional": false,
			"field": "Name"
			"type": "string",
			"optional": false,
			"field": "Password"
		"optional": false,
		"name": "foobar"
	"payload": {      
	  "Email": "",
	  "Login": "login1",
	  "Name": "login1",
	  "Password": "login1#login"
  1. What is the issue in connecting Azure SQL database for kafka connect?
  2. Is there any changes require in config OR topic message produce?

Thanks in advance.

What error are you seeing in the logs or the /status CONNECT REST endpoint?

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.