Re: 一些关于flink rabbitmq connector的疑问

[wx liao]

> 在 2021年10月28日，下午7:53，wx liao <liaowx8...@gmail.com> 写道：
> 
> 你好：
>       
> 冒昧打扰，最近项目在使用flink,sink端是rabbitmq,但是查看项目源码发现RMQSink好像并没有对消息不丢失做保证，没有看到有使用waitForConfirm()或者是confirm
>  listener,想问一下RMQSink部分是否没有保证at least once?希望可以得到解答，谢谢。