You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/09/27 13:05:27 UTC

[flink] branch master updated: [hotfix][docs] Remove the explicit requirement of flink-connector-base, and add missing StartCursor in pulsar connector document.

This is an automated email from the ASF dual-hosted git repository.

arvid pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 7778ab8  [hotfix][docs] Remove the explicit requirement of flink-connector-base, and add missing StartCursor in pulsar connector document.
7778ab8 is described below

commit 7778ab8c1027bac7f9c5e53cc6047278252a4e83
Author: Yufan Sheng <yu...@streamnative.io>
AuthorDate: Fri Sep 24 04:20:50 2021 +0800

    [hotfix][docs] Remove the explicit requirement of flink-connector-base, and add missing StartCursor in pulsar connector document.
---
 docs/content.zh/docs/connectors/datastream/pulsar.md | 4 ----
 docs/content/docs/connectors/datastream/pulsar.md    | 8 ++++----
 2 files changed, 4 insertions(+), 8 deletions(-)

diff --git a/docs/content.zh/docs/connectors/datastream/pulsar.md b/docs/content.zh/docs/connectors/datastream/pulsar.md
index da6380a..a127db9 100644
--- a/docs/content.zh/docs/connectors/datastream/pulsar.md
+++ b/docs/content.zh/docs/connectors/datastream/pulsar.md
@@ -35,10 +35,6 @@ Flink 当前只提供 [Apache Pulsar](https://pulsar.apache.org) 数据源,用
 
 {{< artifact flink-connector-pulsar withScalaVersion >}}
 
-使用本连接器的同时,记得把 `flink-connector-base` 也加到项目的依赖里面:
-
-{{< artifact flink-connector-base >}}
-
 Flink 的流连接器并不会放到发行文件里面一同发布,阅读[此文档]({{< ref "docs/dev/datastream/project-configuration" >}}),了解如何将连接器添加到集群实例内。
 
 ## Pulsar 数据源
diff --git a/docs/content/docs/connectors/datastream/pulsar.md b/docs/content/docs/connectors/datastream/pulsar.md
index 511b39a..680fb1a 100644
--- a/docs/content/docs/connectors/datastream/pulsar.md
+++ b/docs/content/docs/connectors/datastream/pulsar.md
@@ -35,10 +35,6 @@ For details on Pulsar compatibility, please refer to the [PIP-72](https://github
 
 {{< artifact flink-connector-pulsar withScalaVersion >}}
 
-If you are using Pulsar source, `flink-connector-base` is also required as dependency:
-
-{{< artifact flink-connector-base >}}
-
 Flink's streaming connectors are not currently part of the binary distribution.
 See how to link with them for cluster execution [here]({{< ref "docs/dev/datastream/project-configuration" >}}).
 
@@ -244,6 +240,10 @@ Built-in start cursors include:
   ```java
   StartCursor.fromMessageId(MessageId, boolean)
   ```
+- Start from the specified message time by `Message<byte[]>.getEventTime()`.
+  ```java
+  StartCursor.fromMessageTime(long)
+  ```
 
 {{< hint info >}}
 Each Pulsar message belongs to an ordered sequence on its topic.