Kafka Connect JdbcSourceConnector Property Açıklamaları

Giriş

Dokümantasyon burada. Çıktısı şöyle

JdbcSourceTaskConfig values: 

batch.max.rows = 100

catalog.pattern = null

connection.attempts = 3

connection.backoff.ms = 10000

connection.password = [hidden]

connection.url = jdbc:mysql://localhost:52334/test

connection.user = mysql

db.timezone = UTC

dialect.name = 

incrementing.column.name = id

mode = incrementing

numeric.mapping = null

numeric.precision.mapping = false

poll.interval.ms = 5000

query = 

query.retry.attempts = -1

query.suffix = 

quote.sql.identifiers = ALWAYS

schema.pattern = null

table.blacklist = []

table.monitoring.startup.polling.limit.ms = 10000

table.poll.interval.ms = 5000

table.types = [TABLE]

table.whitelist = [dynamic_test_items1, dynamic_test_items2, dynamic_test_items3]

tables = [`test`.`dynamic_test_items1`, `test`.`dynamic_test_items2`, `test`.`dynamic_test_items3`]

timestamp.column.name = []

timestamp.delay.interval.ms = 0

timestamp.granularity = connect_logical

timestamp.initial = null

topic.prefix = 

transaction.isolation.mode = DEFAULT

validate.non.null = true

Bağlantı Bigileri

connection.password

connection.user

connection.url

connection.attempts

connection.backoff.ms

gibi alanlar doldurulur

table.whitelist

Açıklaması şöyle. Eğer belirtilmezse connection'ın erişebildiği tüm tabloları okur

... if you want all tables, just don't include table.whitelist. By default the connector will pull all tables