diff --git a/README.md b/README.md index 2c99626..d6dd1a0 100644 --- a/README.md +++ b/README.md @@ -346,7 +346,6 @@ You can use `org.apache.spark.sql.pulsar.JsonUtils.topicOffsets(Map[String, Mess "earliest". - `endingOffsets` The following are valid values:
@@ -376,6 +375,30 @@ You can use `org.apache.spark.sql.pulsar.JsonUtils.topicOffsets(Map[String, Mess `MessageId.earliest ([8,-1,-1,-1,-1,-1,-1,-1,-1,-1,1,16,-1,-1,-1,-1,-1,-1,-1,-1,-1,1])` is not allowed. + + `startingTime` + A number in unit of milliseconds + No + None + batch queries + + For batch query, You can set a starting offset using milliseconds.
+ The target time of this option is publishTime.
+ Example: `1709254800000` (2024-03-01 01:00:00) + + + + `endingTime` + A number in unit of milliseconds + No + None + batch queries + + For batch query, You can set a ending offset using milliseconds.
+ The target time of this option is publishTime.
+ Example: `1709254800000` (2024-03-01 02:00:00) + + `failOnDataLoss`