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