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

[任庆盛]

您好，

从代码来看 RabbitMQ Sink 的确没有语义保证。目前 RabbitMQ 
由于社区用户不多，相对的维护频率也比较低，如果感兴趣的话也欢迎您参与社区的贡献～



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