Re: [ANNOUNCE] Apache Flink 1.16.0 released

2022-10-28 文章
Congratulations and a big thanks to Chesnay, Martijn, Godfrey and Xingbo for the awesome work for 1.16! Best regards, Qingsheng Ren > On Oct 28, 2022, at 14:46, Xingbo Huang wrote: > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.16.0, which is the fi

Re: [ANNOUNCE] Apache Flink 1.16.0 released

2022-10-28 文章
Congratulations and a big thanks to Chesnay, Martijn, Godfrey and Xingbo for the awesome work for 1.16! Best regards, Qingsheng Ren > On Oct 28, 2022, at 14:46, Xingbo Huang wrote: > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.16.0, which is the fir

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

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