-
Notifications
You must be signed in to change notification settings - Fork 3
/
connector_jdbc_customers_template.config
28 lines (26 loc) · 1.24 KB
/
connector_jdbc_customers_template.config
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
{
"name": "jdbc-customers",
"config": {
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"connection.url": "jdbc:sqlite:$SQLITE_DB_PATH",
"mode": "incrementing",
"incrementing.column.name": "id",
"topic.prefix": "",
"table.whitelist": "customers",
"key.converter": "org.apache.kafka.connect.converters.LongConverter",
"key.converter.schemas.enable": "false",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url": "http://schema-registry:8081",
"transforms": "InsertKey, ExtractId, CastLong, SetValueSchema",
"transforms.InsertKey.type": "org.apache.kafka.connect.transforms.ValueToKey",
"transforms.InsertKey.fields": "id",
"transforms.ExtractId.type": "org.apache.kafka.connect.transforms.ExtractField\$Key",
"transforms.ExtractId.field": "id",
"transforms.CastLong.type": "org.apache.kafka.connect.transforms.Cast\$Key",
"transforms.CastLong.spec": "int64",
"transforms.SetValueSchema.type": "org.apache.kafka.connect.transforms.SetSchemaMetadata\$Value",
"transforms.SetValueSchema.schema.name": "ru.aasmc.avro.eventdriven.Customer",
"transforms.SetValueSchema.schema.version": "1",
"tasks.max": "1"
}
}