You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Yufan Sheng (Jira)" <ji...@apache.org> on 2021/11/24 08:20:00 UTC

[jira] [Comment Edited] (FLINK-25013) flink pulsar connector cannot consume deferred messages

    [ https://issues.apache.org/jira/browse/FLINK-25013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448430#comment-17448430 ] 

Yufan Sheng edited comment on FLINK-25013 at 11/24/21, 8:19 AM:
----------------------------------------------------------------

 !screenshot-1.png|width=400!
The test passed on my local machine. This issue should be closed now.

[~MartijnVisser]


was (Author: syhily):
 !screenshot-1.png! 
The test passed on my local machine. This issue should be closed now.

[~MartijnVisser]

> flink pulsar connector cannot consume deferred messages
> -------------------------------------------------------
>
>                 Key: FLINK-25013
>                 URL: https://issues.apache.org/jira/browse/FLINK-25013
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Pulsar
>    Affects Versions: 1.14.0
>            Reporter: zhangjg
>            Priority: Major
>         Attachments: screenshot-1.png
>
>
>  
> at flink 1.14.0 version ,  pulsar connector ( PulsarSource) cannot consume deferred messages . 
> For the message sent by the producer, the flink pulsar source will be consumed immediately
>  



--
This message was sent by Atlassian Jira
(v8.20.1#820001)