一些关于flink rabbitmq connector的疑问

[wx liao]

你好：
        
冒昧打扰，最近项目在使用flink,sink端是rabbitmq,但是查看项目源码发现RMQSink好像并没有对消息不丢失做保证，没有看到有使用waitForConfirm()或者是confirm
 listener,想问一下RMQSink部分是否没有保证at least once?希望可以得到解答，谢谢。