JesseAtSZ commented on code in PR #9041: URL: https://github.com/apache/seatunnel/pull/9041#discussion_r2013303598
##########
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/config/KafkaSourceOptions.java:
##########
@@ -41,6 +41,12 @@ public class KafkaSourceOptions extends KafkaBaseOptions {
.withDescription(
"Kafka consumer group id, used to distinguish
different consumer groups.");
+ public static final Option<Long> QUEUE_SIZE =
+ Options.key("queue_size")
+ .longType()
+ .defaultValue(1000L)
Review Comment:
changed default value to 1024L
##########
docs/zh/connector-v2/source/Kafka.md:
##########
@@ -56,6 +56,7 @@ 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 定义。
|
+| queue_size | Long | 否
| 1000 | 用于指定读取队列的长度，可以通过调整该参数避免内存溢出。
|
Review Comment:
changed default value to 1024L
--
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]
