Kafka). kafka-client-id Specifies the Kafka client ID of the replication task (optional. TiCDC_sarama_producer_replication ID by default). partition-num The number of the downstream Kafka partitions (optional large-message-handle-compression = "none" This feature is different from the compression feature of the Kafka producer: • The compression algorithm specified in large-message-handle-compression com- presses a single default. Each Pulsar producer corresponds to one topic. If the number �→ of topics you need to replicate is larger than the default value, �→ you need to increase the number. pulsar-producer-cache-size=10240

Kafka). kafka-client-id Specifies the Kafka client ID of the replication task (optional. TiCDC_sarama_producer_replication ID by default). partition-num The number of the downstream Kafka partitions (optional large-message-handle-compression = "none" This feature is different from the compression feature of the Kafka producer: • The compression algorithm specified in large-message-handle-compression com- presses a single default. Each Pulsar producer corresponds to one topic. If the number �→ of topics you need to replicate is larger than the default value, �→ you need to increase the number. pulsar-producer-cache-size=10240

最高版本为 3.2.0。该值需要与下游 Kafka 的实际版本保持一致）。 kafka-client-id 指定同步任务的 Kafka 客户端的 ID（可选，默认值为 TiCDC_sarama_producer_同步任务的 ID）。 partition-num 下游 Kafka partition 数量（可选，不能大于实际 partition 数量，否则创建同步任 务会失败，默认值 3）。 max-message-bytes ##### 可选值有 "none"、"lz4"、"snappy"，默认为 "none" large-message-handle-compression = "none" 该功能和 Kafka producer 的压缩功能不同： • large-message-handle-compression 中指定的压缩算法，它启用的是对单条 Kafka 消息进行压缩，并且 压缩是在与消息大小限制参数比较之前进行。 oauth2.oauth2-scope="xxxx" ##### TiCDC 中缓存 Pulsar Producer 的个数，默认上限为 10240 个。每个 Pulsar Producer 对应一个 �→ topic，如果你需要同步的 topic 数量大于默认值，则需要调大该数量。 pulsar-producer-cache-size=10240 ##### Pulsar 数据压缩方式，默认不压缩，可选值为

最高版本为 3.2.0。该值需要与下游 Kafka 的实际版本保持一致）。 kafka-client-id 指定同步任务的 Kafka 客户端的 ID（可选，默认值为 TiCDC_sarama_producer_同步任务的 ID）。 partition-num 下游 Kafka partition 数量（可选，不能大于实际 partition 数量，否则创建同步任 务会失败，默认值 3）。 max-message-bytes ##### 可选值有 "none"、"lz4"、"snappy"，默认为 "none" large-message-handle-compression = "none" 该功能和 Kafka producer 的压缩功能不同： • large-message-handle-compression 中指定的压缩算法，它启用的是对单条 Kafka 消息进行压缩，并且 压缩是在与消息大小限制参数比较之前进行。 oauth2.oauth2-scope="xxxx" ##### TiCDC 中缓存 Pulsar Producer 的个数，默认上限为 10240 个。每个 Pulsar Producer 对应一个 �→ topic，如果你需要同步的 topic 数量大于默认值，则需要调大该数量。 pulsar-producer-cache-size=10240 ##### Pulsar 数据压缩方式，默认不压缩，可选值为

最高版本为 3.2.0。该值需要与下游 Kafka 的实际版本保持一致）。 kafka-client-id 指定同步任务的 Kafka 客户端的 ID（可选，默认值为 TiCDC_sarama_producer_同步任务的 ID）。 partition-num 下游 Kafka partition 数量（可选，不能大于实际 partition 数量，否则创建同步任 务会失败，默认值 3）。 max-message-bytes ##### 可选值有 "none"、"lz4"、"snappy"，默认为 "none" large-message-handle-compression = "none" 该功能和 Kafka producer 的压缩功能不同： • large-message-handle-compression 中指定的压缩算法，它启用的是对单条 Kafka 消息进行压缩，并且 压缩是在与消息大小限制参数比较之前进行。 oauth2.oauth2-scope="xxxx" ##### TiCDC 中缓存 Pulsar Producer 的个数，默认上限为 10240 个。每个 Pulsar Producer 对应一个 �→ topic，如果你需要同步的 topic 数量大于默认值，则需要调大该数量。 pulsar-producer-cache-size=10240 ##### Pulsar 数据压缩方式，默认不压缩，可选值为

最高版本为 3.2.0。该值需要与下游 Kafka 的实际版本保持一致）。 kafka-client-id 指定同步任务的 Kafka 客户端的 ID（可选，默认值为 TiCDC_sarama_producer_同步任务的 ID）。 partition-num 下游 Kafka partition 数量（可选，不能大于实际 partition 数量，否则创建同步任 务会失败，默认值 3）。 max-message-bytes ##### 可选值有 "none"、"lz4"、"snappy"，默认为 "none" large-message-handle-compression = "none" 该功能和 Kafka producer 的压缩功能不同： • large-message-handle-compression 中指定的压缩算法，它启用的是对单条 Kafka 消息进行压缩，并且 压缩是在与消息大小限制参数比较之前进行。 oauth2.oauth2-scope="xxxx" ##### TiCDC 中缓存 Pulsar Producer 的个数，默认上限为 10240 个。每个 Pulsar Producer 对应一个 �→ topic，如果你需要同步的 topic 数量大于默认值，则需要调大该数量。 pulsar-producer-cache-size=10240 ##### Pulsar 数据压缩方式，默认不压缩，可选值为

Kafka). kafka-client-id Specifies the Kafka client ID of the replication task (optional. TiCDC_sarama_producer_replication ID by default). partition-num The number of the downstream Kafka partitions (optional large-message-handle-compression = "none" This feature is different from the compression feature of the Kafka producer: • The compression algorithm specified in large-message-handle-compression com- presses a single default. Each Pulsar producer corresponds to one topic. If the number �→ of topics you need to replicate is larger than the default value, �→ you need to increase the number. pulsar-producer-cache-size=10240

Kafka). kafka-client-id Specifies the Kafka client ID of the replication task (optional. TiCDC_sarama_producer_replication ID by default). partition-num The number of the downstream Kafka partitions (optional large-message-handle-compression = "none" This feature is different from the compression feature of the Kafka producer: • The compression algorithm specified in large-message-handle-compression com- presses a single default. Each Pulsar producer corresponds to one topic. If the number �→ of topics you need to replicate is larger than the default value, �→ you need to increase the number. pulsar-producer-cache-size=10240

Kafka. kafka-client-id Specifies the Kafka client ID of the replication task (optional. TiCDC_sarama_producer_replication ID by default). partition-num The number of the downstream Kafka partitions (optional protocol to decode the data. This feature is different from the compression feature of the Kafka producer: • The compression algorithm specified in large-message-handle-compression com- presses a single default. Each Pulsar producer corresponds to one topic. If the number �→ of topics you need to replicate is larger than the default value, �→ you need to increase the number. pulsar-producer-cache-size=10240

Kafka. kafka-client-id Specifies the Kafka client ID of the replication task (optional. TiCDC_sarama_producer_replication ID by default). partition-num The number of the downstream Kafka partitions (optional protocol to decode the data. This feature is different from the compression feature of the Kafka producer: • The compression algorithm specified in large-message-handle-compression com- presses a single default. Each Pulsar producer corresponds to one topic. If the number �→ of topics you need to replicate is larger than the default value, �→ you need to increase the number. pulsar-producer-cache-size=10240