I am one of the Forum Moderators for RabbitMQ, which does have a lot of
active users. :)
If you have any questions about RMQ please subscribe to its official group
and ask there.
[email protected]

Regards.


On Fri, Oct 29, 2021 at 11:09 AM 任庆盛 <[email protected]> wrote:

> 您好,
>
> 从代码来看 RabbitMQ Sink 的确没有语义保证。目前 RabbitMQ
> 由于社区用户不多,相对的维护频率也比较低,如果感兴趣的话也欢迎您参与社区的贡献~
>
>
>
> > 2021年10月28日 下午7:53,wx liao <[email protected]> 写道:
> >
> > 你好:
> >
>  
> 冒昧打扰,最近项目在使用flink,sink端是rabbitmq,但是查看项目源码发现RMQSink好像并没有对消息不丢失做保证,没有看到有使用waitForConfirm()或者是confirm
> listener,想问一下RMQSink部分是否没有保证at least once?希望可以得到解答,谢谢。
>
>

回复