Hisoka-X commented on code in PR #9041: URL: https://github.com/apache/seatunnel/pull/9041#discussion_r2016489959
##########
docs/en/connector-v2/source/Kafka.md:
##########
@@ -56,6 +56,8 @@ They can be downloaded via install-plugin.sh or from the
Maven central repositor
| common-options |
| No | - |
Source plugin common parameters, please refer to [Source Common
Options](../source-common-options.md) for details
|
| protobuf_message_name | String
| No | - |
Effective when the format is set to protobuf, specifies the Message name
|
| protobuf_schema | String
| No | - |
Effective when the format is set to protobuf, specifies the Schema definition
|
+| reader_cache_queue_size | Integer
| No | 1024 |
Specify the length of the read queue, which can be adjusted to avoid memory
overflow.
|
Review Comment:
```suggestion
| reader_cache_queue_size | Integer
| No | 1024 |
The reader shard cache queue is used to cache the data corresponding to the
shards. The size of the shard cache depends on the number of shards obtained by
each reader, rather than the amount of data in each shard.
|
```
##########
docs/zh/connector-v2/source/Kafka.md:
##########
@@ -56,7 +56,8 @@ import ChangeLog from '../changelog/connector-kafka.md';
| common-options | |
否 | - | 源插件的常见参数，详情请参考 [Source Common
Options](../source-common-options.md)。
|
| protobuf_message_name | String |
否 | - | 当格式设置为 protobuf 时有效，指定消息名称。
|
| protobuf_schema | String |
否 | - | 当格式设置为 protobuf 时有效，指定 Schema 定义。
|
-| is_native | Boolean
| No | false |
支持保留record的源信息。
|
+| reader_cache_queue_size | Integer |
否 | 1024 | 用于指定读取队列的长度，可以通过调整该参数避免内存溢出。
|
Review Comment:
```suggestion
| reader_cache_queue_size | Integer
| 否 | 1024 |
Reader分片缓存队列，用于缓存分片对应的数据。占用大小取决于每个reader得到的分片量，而不是每个分片的数据量。
|
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
