TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： – type: * open * closed "http://localhost:80801/subjects/{subject-name}/versions/{version-number}/ �→ schema" #### 编码数据时所用编码器的线程数。 #### 默认值为 16。 #### 注意：该参数只有当下游为消息队列时，才会生效。 #### encoder-concurrency = 16 #### 是否开启 Kafka Sink day。默 认值为 none，即不使用日期分隔。（非必选） dispatchers 事件分发配置数组。（非必选） encoder_ �→ concurrency INT 类型。MQ sink 中编码器的线程数。默认值为 16。（非必选） protocol STRING 类型，对于 MQ 类的 Sink，可以指定消息的协议格式。目前支持以下协议： canal-json、open-protocol、avro

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： – type: * open * closed "http://localhost:80801/subjects/{subject-name}/versions/{version-number}/ �→ schema" #### 编码数据时所用编码器的线程数。 #### 默认值为 16。 #### 注意：该参数只有当下游为消息队列时，才会生效。 1978 #### encoder-concurrency = 16 #### 是否开启 Kafka day。 默认值为 none，即不使用日期分隔。（非必选） dispatchers 事件分发配置数组。（非必选） encoder_ �→ concurrency INT 类型。MQ sink 中编码器的线程数。默认值为 16。（非必选） protocol STRING 类型，对于 MQ 类的 Sink，可以指定消息的协议格式。目前支持以下协议： canal-json、open-protocol、avro

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： 750 – type: * open

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： 728 – type: * open

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： – type: * open * closed "http://localhost:80801/subjects/{subject-name}/versions/{version-number}/ �→ schema" #### 编码数据时所用编码器的线程数。 #### 默认值为 32。 #### 注意：该参数只有当下游为消息队列时，才会生效。 #### encoder-concurrency = 32 #### 是否开启 Kafka Sink day。默 认值为 none，即不使用日期分隔。（非必选） dispatchers 事件分发配置数组。（非必选） encoder_ �→ concurrency INT 类型。MQ sink 中编码器的线程数。默认值为 16。（非必选） protocol STRING 类型，对于 MQ 类的 Sink，可以指定消息的协议格式。目前支持以下协议： canal-json、open-protocol、avro

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： – type: * open * closed "http://localhost:80801/subjects/{subject-name}/versions/{version-number}/ �→ schema" #### 编码数据时所用编码器的线程数。 #### 默认值为 32。 #### 注意：该参数只有当下游为消息队列时，才会生效。 #### encoder-concurrency = 32 #### 是否开启 Kafka Sink day。默 认值为 none，即不使用日期分隔。（非必选） dispatchers 事件分发配置数组。（非必选） encoder_ �→ concurrency INT 类型。MQ sink 中编码器的线程数。默认值为 16。（非必选） protocol STRING 类型，对于 MQ 类的 Sink，可以指定消息的协议格式。目前支持以下协议： canal-json、open-protocol、avro

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： – type: * open * closed "http://localhost:80801/subjects/{subject-name}/versions/{version-number}/ �→ schema" #### 编码数据时所用编码器的线程数。 #### 默认值为 32。 #### 注意：该参数只有当下游为消息队列时，才会生效。 #### encoder-concurrency = 32 #### 是否开启 Kafka Sink day。默 认值为 none，即不使用日期分隔。（非必选） dispatchers 事件分发配置数组。（非必选） encoder_ �→ concurrency INT 类型。MQ sink 中编码器的线程数。默认值为 16。（非必选） protocol STRING 类型，对于 MQ 类的 Sink，可以指定消息的协议格式。目前支持以下协议： canal-json、open-protocol、avro

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： – type: * open * closed "http://localhost:80801/subjects/{subject-name}/versions/{version-number}/ �→ schema" #### 编码数据时所用编码器的线程数。 #### 默认值为 32。 #### 注意：该参数只有当下游为消息队列时，才会生效。 #### encoder-concurrency = 32 #### 是否开启 Kafka Sink none、year、month 和 day。默认值为 none，即不使用日期分隔。（非必选） dispatchers 事件分发配置数组。（非必选） encoder_concurrency INT 类型。MQ sink 中编码器的线程数。默认值为 16。（非必选） protocol STRING 类型，对于 MQ 类的 Sink，可以指定消息的协议格式。目前支持以下协 议：canal-json、open-protocol、avro

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： – type: * open * closed

TiDB Lightning 比 TiKV Importer 快，导致 TiDB Lightning 延迟 • lightning_kv_encoder（计数器） 计算已开启及关闭的 KV 编码器。KV 编码器是运行于内存的 TiDB 实例，用于将 SQL 的 INSERT 语句转换成 键值对。此度量的净值（开启减掉关闭）在正常情况下不应持续增长。标签： – type: * open * closed "http://localhost:80801/subjects/{subject-name}/versions/{version-number}/ �→ schema" #### 编码数据时所用编码器的线程数。 #### 默认值为 32。 #### 注意：该参数只有当下游为消息队列时，才会生效。 #### encoder-concurrency = 32 2308 #### 是否开启 Kafka none、year、month 和 day。默认值为 none，即不使用日期分隔。（非必选） dispatchers 事件分发配置数组。（非必选） encoder_concurrency INT 类型。MQ sink 中编码器的线程数。默认值为 16。（非必选） protocol STRING 类型，对于 MQ 类的 Sink，可以指定消息的协议格式。目前支持以下协 议：canal-json、open-protocol、avro、debezium