[
https://issues.apache.org/jira/browse/FLINK-28506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng closed FLINK-28506.
-------------------------------
Resolution: Duplicate
> Pulsar sink don't support zero timestamp which may be provided by flink
> -----------------------------------------------------------------------
>
> Key: FLINK-28506
> URL: https://issues.apache.org/jira/browse/FLINK-28506
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.15.0
> Reporter: Yufan Sheng
> Priority: Minor
>
> The timestamp from flink's SinkWriter.Context#timestamp() could be zero. This
> is not allowed in Pulsar. We should filter the invalid timestamp when sinking
> the message in the Pulsar connector.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
