WenDing-Y commented on code in PR #9318: URL: https://github.com/apache/seatunnel/pull/9318#discussion_r2093901015
##########
docs/en/connector-v2/source/Kafka.md:
##########
@@ -58,6 +58,7 @@ They can be downloaded via install-plugin.sh or from the
Maven central repositor
| protobuf_schema | String
| No | - |
Effective when the format is set to protobuf, specifies the Schema definition
|
| 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.
|
| is_native | Boolean
| No | false |
Supports retaining the source information of the record.
+| start_mode.endTimestamp | Long
| No | - |
The end time required for consumption mode to be "timestamp",in batch mode
Review Comment:
done
--
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]
