开云体育官方注册网址Debezium MySQL连接器

布尔，保龄球

布尔

N/A

位(1)

布尔

N/A

比特(> 1)

字节

io.开云体育官方注册网址debezium.data.Bits

的长度模式参数包含表示比特数的整数。由此产生的byte []将包含小端序形式的位，并将大小调整为至少包含指定位数(例如，numBytes = n/8 + (n%8== 0 ?0: 1)在哪里n是比特数)。

非常小的整数

INT8

N/A

短整型((M))

INT16

N/A

MEDIUMINT ((M))

INT32

N/A

INT，整数((M))

INT32

N/A

长整型数字((M))

INT64

N/A

真正的((M, D))

FLOAT32

N/A

浮动((M, D))

FLOAT64

N/A

双((M, D))

FLOAT64

N/A

CHAR (M))

字符串

N/A

VARCHAR (M))

字符串

N/A

二进制(M))

字节

N/A

VARBINARY (M))

字节

N/A

TINYBLOB

字节

N/A

非常小的文本串

字符串

N/A

团

字节

N/A

文本

字符串

N/A

MEDIUMBLOB

字节

N/A

简单

字符串

N/A

LONGBLOB

字节

N/A

量变

字符串

N/A

JSON

字符串

io.开云体育官方注册网址debezium.data.Json

包含JSON文档、数组或标量的字符串表示形式。

枚举

字符串

io.开云体育官方注册网址debezium.data.Enum

的允许Schema参数包含以逗号分隔的允许值列表。

集

字符串

io.开云体育官方注册网址debezium.data.EnumSet

的允许Schema参数包含以逗号分隔的允许值列表。

年[(2 | 4)]

INT32

io.开云体育官方注册网址debezium.time.Year

的名字

连接器的唯一名称。尝试使用相同的名称再次注册将失败。(所有Kafka Connect连接器都需要这个属性。)

connector.class

连接器的Java类的名称。始终使用值io.开云体育官方注册网址debezium.connector.mysql.MySqlConnectorMySQL连接器。

tasks.max

1

应该为此连接器创建的最大任务数。MySQL连接器总是使用单个任务，因此不使用这个值，所以默认值总是可以接受的。

开云体育电动老虎机database.hostname

MySQL数据库服务器的IP地址或主机名。开云体育电动老虎机

开云体育电动老虎机database.port

3306

MySQL数据库服务器的整型端口号。开云体育电动老虎机

开云体育电动老虎机database.user

连接MySQL数据库服务器时使用的M开云体育电动老虎机ySQL数据库名称。

开云体育电动老虎机database.password

连接MySQL数据库服务器时使用的密码。开云体育电动老虎机

开云体育电动老虎机database.server.name

逻辑名称，用于标识并提供被监视的特定MySQL数据库服务器/集群的名称空间。开云体育电动老虎机逻辑名在所有其他连接器中应该是唯一的，因为它被用作从该连接器发出的所有Kafka主题名的前缀。

开云体育电动老虎机database.server.id

随机

这个数据库客户端的数字ID，在MySQL集开云体育电动老虎机群中所有当前运行的数据库进程中必须是唯一的。这个连接器作为另一个服务器(使用这个唯一的ID)加入MySQL开云体育电动老虎机数据库集群，因此它可以读取binlog。默认情况下，生成一个介于5400和6400之间的随机数，尽管我们建议设置一个显式值。

开云体育电动老虎机database.history.kafka.topic

Kafka主题的全称，连接器将在其中存储数据库模式历史。开云体育电动老虎机

开云体育电动老虎机database.history.kafka.bootstrap.servers

一个主机/端口对列表，连接器将使用它建立到Kafka集群的初始连接。此连接将用于检索以前由连接器存储的数据库模式历史，并用于写入从源数据库读取的每个DDL语开云体育电动老虎机句。这应该指向Kafka Connect进程使用的相同的Kafka集群。

开云体育电动老虎机database.whitelist

空字符串

一个可选的逗号分隔的正则表达式列表，匹配要监控的数据库名称;开云体育电动老虎机任何未包开云体育电动老虎机含在白名单中的数据库名称都将被排除在监视之外。默认情况下，将监视所有数据库。开云体育电动老虎机不得与开云体育电动老虎机database.blacklist．

开云体育电动老虎机database.blacklist

空字符串

可选的逗号分隔的正则表达式列表，匹配要排除在监视之外的数据库名称;开云体育电动老虎机任何未包开云体育电动老虎机含在黑名单中的数据库名称都将被监控。不得与开云体育电动老虎机database.whitelist．

table.whitelist

空字符串

一个可选的逗号分隔的正则表达式列表，它匹配要监控的表的完全限定表标识符;任何不在白名单中的表都将被排除在监控之外。每个标识符都是这样的开云体育电动老虎机数据库名．的表．默认情况下，连接器将监视每个被监视数据库中的每个非系统表。开云体育电动老虎机不得与table.blacklist．

table.blacklist

空字符串

一个可选的逗号分隔的正则表达式列表，它与要排除在监视之外的表的完全限定表标识符匹配;任何不在黑名单中的表都将被监控。每个标识符都是这样的开云体育电动老虎机数据库名．的表．不得与table.whitelist．

column.blacklist

空字符串

一个以逗号分隔的可选正则表达式列表，该列表与应从更改事件消息值中排除的列的完全限定名称匹配。列的完全限定名的格式为开云体育电动老虎机数据库名．的表．columnName,或开云体育电动老虎机数据库名．schemaName．的表．columnName．

column.truncate.to。长度.chars

N/A

一个以逗号分隔的可选正则表达式列表，它与基于字符的列的完全限定名匹配，如果字段值长于指定的字符数，则这些列的值应在更改事件消息值中被截断。可以在单个配置中使用具有不同长度的多个属性，尽管每个属性的长度必须为正整数。列的完全限定名的格式为开云体育电动老虎机数据库名．的表．columnName,或开云体育电动老虎机数据库名．schemaName．的表．columnName．

column.mask.with。长度.chars

N/A

一个以逗号分隔的可选正则表达式列表，该列表与基于字符的列的完全限定名称匹配，这些列的值应在更改事件消息值中被替换为由指定数量的星号(＊)字符。可以在单个配置中使用具有不同长度的多个属性，尽管每个属性的长度必须为正整数或零。列的完全限定名的格式为开云体育电动老虎机数据库名．的表．columnName,或开云体育电动老虎机数据库名．schemaName．的表．columnName．

column.propagate.source.type

N/A

一个以逗号分隔的可选正则表达式列表，它与列的完全限定名称相匹配，这些列的原始类型和长度应该作为参数添加到发出的更改消息中的相应字段模式中。模式参数__开云体育官方注册网址debezium.source.column.type，__开云体育官方注册网址debezium.source.column.length而且_开云体育官方注册网址debezium.source.column.scale将分别用于传播原始类型名称和长度(对于变宽类型)。对于接收器数据库中相应列的适当大小很有用。开云体育电动老虎机列的完全限定名的格式为开云体育电动老虎机数据库名．的表．columnName,或开云体育电动老虎机数据库名．schemaName．的表．columnName．

time.precision.mode

adaptive_time_microseconds

时间、日期和时间戳可以用不同的精度表示，包括:adaptive_time_microseconds(默认值)根据数据库列的类型，使用毫秒、微秒或纳秒精度值捕获数据库中的日期、datetime和时间戳值，TIME类型字段除外，它总是以微秒为单位捕获;开云体育电动老虎机自适应(已弃用)根据数据库列的类型，使用毫秒、微秒或纳秒精度值捕获与数据库中完全相同的时间和时间戳值;开云体育电动老虎机或连接总是使用Kafka Connect内置的时间、日期和时间戳表示来表示时间和时间戳值，无论数据库列的精度如何，它都使用毫秒精度。开云体育电动老虎机看到时间值．

decimal.handling.mode

精确的

指定连接器应如何处理的值小数而且数字列:精确的(默认值)精确地表示它们使用java.math.BigDecimal变更事件中以二进制形式表示的值;或双表示它们使用双值，这可能会导致精度的损失，但将更容易使用。字符串选项将值编码为格式化的字符串，这很容易使用，但关于真实类型的语义信息会丢失。看到十进制值．

bigint.unsigned.handling.mode

长

指定BIGINT UNSIGNED列应该如何在更改事件中表示，包括:精确的使用java.math.BigDecimal来表示值，这些值使用二进制表示和Kafka Connect的方式编码在更改事件中org.apache.kafka.connect.data.Decimal类型;长(默认值)表示使用Java的值长这种方法可能无法提供精准度，但消费者使用起来要容易得多。长通常是更可取的设置。仅当处理大于2^63的值时，精确的设置应该使用，因为这些值不能传达使用长．看到数据类型．

include.schema.changes

真正的

布尔值，指定连接器是否应该将数据库模式中的更改发布到与数据库服务器ID同名的Kafka主题。开云体育电动老虎机每个模式更改将使用一个包含数据库名称的键记录，该键的值包括DDL语句。开云体育电动老虎机这与连接器内部记录数据库历史的方式无关。开云体育电动老虎机默认为真正的．

include.query

假

布尔值，该值指定连接器是否应包括生成更改事件的原始SQL查询。
注意:该选项要求MySQL将binlog_rows_query_log_events选项设置为ON。查询将不会显示快照进程生成的事件。
警告:启用此选项可能会在更改事件中包含原始SQL语句，从而显式地暴露被列入黑名单或屏蔽的表或字段。因此，该选项默认为“false”。

event.deserialization.failure.handling.mode

失败

指定连接器在反序列化binlog事件期间应对异常的方式。失败将传播异常(指示有问题的事件及其binlog偏移量)，导致连接器停止。
警告将导致跳过有问题的事件，并记录有问题的事件及其binlog偏移量(确保日志记录器设置为警告或错误级别)。
忽略会引起问题的事件将被跳过。

inconsistent.schema.handling.mode

失败

指定连接器应该如何响应与表相关的binlog事件，这些事件不存在于内部模式表示中(即内部表示与数据库不一致)开云体育电动老虎机失败将抛出异常(指示有问题的事件及其binlog偏移量)，导致连接器停止。
警告将导致跳过有问题的事件，并记录有问题的事件及其binlog偏移量(确保日志记录器设置为警告或错误级别)。
忽略将导致跳过有问题的事件。

max.queue.size

8192

正整数值，指定阻塞队列的最大大小，从数据库日志中读取的更改事件在写入Kafka之前被放置在其中。开云体育电动老虎机例如，当写入Kafka较慢或Kafka不可用时，该队列可以为binlog阅读器提供反压力。出现在队列中的事件不包括在此连接器定期记录的偏移量中。属性中指定的最大批处理大小，默认值为8192max.batch.size财产。

max.batch.size

2048

正整数值，指定在此连接器的每次迭代期间应处理的每批事件的最大大小。默认为2048年。

poll.interval.ms

1000

正整数值，指定连接器在每次迭代期间等待新更改事件出现的毫秒数。缺省值为1000毫秒，即1秒。

connect.timeout.ms

30000

一个正整数值，指定连接器在尝试连接到MySQL数据库服务器后超时前应该等待的最大时间(以毫秒为单位)。开云体育电动老虎机默认为30秒。

gtid.source.includes

一个用逗号分隔的正则表达式列表，它匹配GTID集中的源uuid，用于查找MySQL服务器中的binlog位置。只有源匹配其中一个包含模式的GTID范围才会被使用。不得与gtid.source.excludes．

gtid.source.excludes

一个用逗号分隔的正则表达式列表，它匹配GTID集中的源uuid，用于查找MySQL服务器中的binlog位置。只有源不匹配这些排除模式的GTID范围才会被使用。不得与gtid.source.includes．

gtid.new.channel.position

最新的

当设置为最新的，当连接器看到一个新的GTID通道时，它将从该GTID通道中最后执行的事务开始消费。如果设置为最早的，连接器开始从第一个可用(未清除的)GTID位置读取该通道。最早的当你有一个主-被动的MySQL设置，其中Debezium连接到主，在这种情况下，在故障转移期间，具有新UUID(和GT开云体育官方注册网址ID通道)的从服务器在Debezium连接之前开始接收写。这些写操作在使用时会丢失最新的．

tombstones.on.delete

真正的

控制是否在删除事件之后生成墓碑事件。
当真正的删除操作由删除事件和后续的墓碑事件表示。当假只发送一个删除事件。
触发墓碑事件(默认行为)允许Kafka在源记录被删除后完全删除与给定键相关的所有事件。

connect.keep.alive

真正的

一个布尔值，指定是否应该使用一个单独的线程来确保与MySQL服务器/集群的连接保持活跃。

table.ignore.builtin

真正的

布尔值，指定是否应忽略内置系统表。无论表是白名单还是黑名单，这都适用。默认情况下，系统表被排除在监视之外，当对任何系统表进行更改时，不会生成任何事件。

开云体育电动老虎机database.history.kafka.recovery.poll.interval.ms

One hundred.

一个整数值，指定连接器在启动/恢复期间轮询持久数据时应等待的最大毫秒数。默认值是100ms。

开云体育电动老虎机database.history.kafka.recovery.attempts

4

在连接器恢复失败并发生错误之前，连接器应尝试读取持久历史数据的最大次数。接收不到数据后等待的最大时间为recovery.attemptsxrecovery.poll.interval.ms．

开云体育电动老虎机database.history.skip.unparseable.ddl

假

布尔值，指定连接器是否应忽略格式错误或未知的数据库语句，或停止处理并让操作员修复问题。开云体育电动老虎机安全默认值为假．在处理binlog时，应该小心使用跳过，因为它可能导致数据丢失或损坏。

开云体育电动老虎机database.history.store.only.monitored.tables.ddl

假

布尔值，指定连接器是否应该记录所有DDL语句或(当真正的)只有那些与Debezium监视的表相关的(通过过滤器配置)。开云体育官方注册网址安全默认值为假．使用此特性时应格外小心，因为更改过滤器时可能需要丢失数据。

开云体育电动老虎机database.ssl.mode

禁用

指定是否使用加密连接。默认为禁用，并指定使用未加密的连接。

的首选选项将在服务器支持安全连接时建立加密连接，否则将退回到未加密连接。

的要求选项建立加密连接，但如果由于任何原因无法建立连接，则会失败。

的verify_ca选项表现为要求但是另外，它会根据配置的证书颁发机构(CA)证书验证服务器TLS证书，如果它不匹配任何有效的CA证书，则会失败。

的verify_identity选项表现为verify_ca但是还要验证服务器证书是否与远程连接的主机相匹配。

binlog.buffer.size

0

binlog读取器使用的预读缓冲区的大小。
在特定的条件下，MySQL binlog可能包含未提交的数据回滚声明。典型的例子是在单个事务中使用保存点或混合临时和常规的表更改。
当检测到事务的开始时，Debezium尝试前滚binlog位置并找到其中任何一个开云体育官方注册网址提交或回滚因此，它可以决定是否将来自事务的更改流化。缓冲区的大小定义了Debezium在搜索事务边界时可以缓冲的事务更改的最大数量。开云体育官方注册网址如果事务的大小大于缓冲区，则Debezium需要在流处理时倒带并重新读取缓冲区中不适合的事件。开云体育官方注册网址价值0禁用缓冲。
默认禁用。
注意:这个特性应该被认为是一个正在孵化的特性。我们需要客户的反馈，但预计它不是完全抛光。

snapshot.mode

最初的

指定在连接器启动时运行快照的条件。默认为最初的，并指定只有在没有为逻辑服务器名记录偏移量时连接器才能运行快照。的when_needed选项指定连接器在启动时运行一个快照，只要它认为有必要(当没有可用的偏移量，或者当以前记录的偏移量指定一个binlog位置或GTID在服务器中不可用时)。的从来没有选项指定连接永远不应该使用快照，并且在第一次启动时使用逻辑服务器名，连接器应该从binlog的开头读取;这应该小心使用，因为只有当binlog保证包含数据库的整个历史时，它才有效。开云体育电动老虎机如果不需要主题包含数据的一致快照，而只需要它们具有自连接器启动以来的更改，则可以使用schema_only选项，其中连接器仅快照模式(而不是数据)。

schema_only_recovery是现有连接器的恢复选项，用于恢复损坏或丢失的数据库历史主题，或定期“清理”可能意外增长的数据库历史主题(需要无限保留)。开云体育电动老虎机

snapshot.locking.mode

最小的

控制连接器在执行快照时是否保持全局MySQL读锁(防止对数据库的任何更新)以及保持多长时间。开云体育电动老虎机有三个可能的值最小的，扩展,没有一个．

最小的当连接器读取数据库模式和其他元数据时，连接器仅为快照的初始部分持有全局读锁。开云体育电动老虎机快照中的其余工作包括从每个表中选择所有行，即使不再持有全局读锁并且其他MySQL客户端正在更新数据库，也可以使用REPEATABLE READ事务以一致的方式完成这一工作。开云体育电动老虎机

扩展在某些情况下，客户端正在提交MySQL从REPEATABLE READ语义中排除的操作，可能需要在快照的整个持续时间内阻塞所有写操作。对于这些情况，请使用此选项。

没有一个将防止连接器在快照过程中获取任何表锁。此值可用于所有快照模式，但如果和使用该值是安全的只有如果在拍摄快照时没有发生模式更改。注意，对于用MyISAM引擎定义的表，尽管设置了这个属性，当MyISAM获取表锁时，表仍然是锁定的。这种行为与InnoDB引擎不同，InnoDB引擎需要行级锁。

snapshot.select.statement.overrides

控制快照中将包括表中的哪些行。
此属性包含以逗号分隔的全限定表列表(DB_NAME.TABLE_NAME)．在进一步的配置属性中为各个表指定选择语句，每个表一个，由id标识snapshot.select.statement.overrides。[DB_NAME] [TABLE_NAME]。．这些属性的值是在快照期间从特定表检索数据时使用的SELECT语句。对于大型只能追加的表，一个可能的用例是设置一个特定的开始(恢复)快照的点，以防之前的快照被中断。
请注意:仅对快照有影响。从binlog捕获的事件完全不受它的影响。

min.row.count.to.stream.results

1000

在快照操作期间，连接器将查询每个包含的表，以便为该表中的所有行产生读取事件。这个参数决定MySQL连接是否将一个表的所有结果拉入内存(这很快，但需要大量内存)，还是将结果流化(可能较慢，但适用于非常大的表)。该值指定在连接器将结果流传输之前表必须包含的最小行数，默认为1,000。将此参数设置为“0”将跳过所有表大小检查，并在快照期间始终流所有结果。

heartbeat.interval.ms

0

控制心跳消息的发送频率。
此属性包含以毫秒为单位的间隔，该间隔定义连接器向心跳主题发送心跳消息的频率。将此参数设置为0完全不发送心跳消息。
默认禁用。

heartbeat.topics.prefix

__开云体育官方注册网址debezium-heartbeat

控制要向其发送心跳消息的主题的命名。
主题根据模式命名< heartbeat.topics.prefix >。< server.name >．

开云体育电动老虎机database.initial.statements

当建立到数据库的JDBC连接(不是事务日志读取连接)时，将执行的SQL语句的分号列表。开云体育电动老虎机使用双分号(';;')将分号用作字符而不是分隔符。
注意:连接器可以根据自己的判断建立JDBC连接，因此这通常只用于配置会话参数，而不是用于执行DML语句。

snapshot.delay.ms

连接器启动后在快照之前应该等待的间隔(以毫秒为单位);
可用于在启动集群中的多个连接器时避免快照中断，这可能导致连接器的重新平衡。

snapshot.fetch.size

指定在进行快照时应一次性从每个表读取的最大行数。连接器将以这个大小的多个批次读取表内容。

enable.time.adjuster

MySQL允许用户插入2位或4位的年份值。如果是两位数字，值将自动映射到1970 - 2069范围。这通常由数据库完成。开云体育电动老虎机
设置为真正的(默认值)当Debezium应该做转换开云体育官方注册网址。
设置为假当转换完全委托给数据库时。开云体育电动老虎机

source.struct.version

v2

的架构版本源阻断CDC事件;开云体育官方注册网址Debezium 0.10引入了一些突破
的结构的更改源块，以便在所有连接器之间统一暴露的结构。
通过将此选项设置为v1可以生成早期版本中使用的结构。注意，不建议使用这种设置，并计划在未来的Debezium版本中删除。开云体育官方注册网址