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.