Skip to content
This repository has been archived by the owner on Dec 14, 2022. It is now read-only.

[BUG] Delay messages are not supported for the flink pulsar #470

Open
kukuzidian opened this issue Nov 23, 2021 · 1 comment
Open

[BUG] Delay messages are not supported for the flink pulsar #470

kukuzidian opened this issue Nov 23, 2021 · 1 comment
Labels

Comments

@kukuzidian
Copy link

Describe the bug
A clear and concise description of what the bug is.

  1. Flink pulsar source consumption does not support delayed messages. 消费端不支持延迟消费

  2. Flick pulsar sink sending does not support delayed messages 发送端不支持发送,属性设置无效

  3. java 原生客户端 ,发送端支持延迟消息;消费端在独占模式下,不支持延迟消费。

测试连接器: pulsar-flink-connector_2.11 版本: 1.13.1.4

@kukuzidian kukuzidian changed the title [BUG] Delay messages are not supported for the flick pulsar [BUG] Delay messages are not supported for the flink pulsar Dec 13, 2021
@kukuzidian
Copy link
Author

测试连接器: pulsar-flink-connector_2.11 版本: 1.13.1.4 ; FlinkPulsarSource数据源,订阅类型不能通过属性设置为Shared。因此导致不能消费延迟消息。
见图片截图,订阅模式属性配置失效:
flinkdelay

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
Projects
None yet
Development

No branches or pull requests

1 participant