[
https://issues.apache.org/jira/browse/FLINK-24619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437782#comment-17437782
]
liwei li commented on FLINK-24619:
----------------------------------
https://issues.apache.org/jira/browse/FLINK-21373
https://issues.apache.org/jira/browse/FLINK-20628
> rabbit not support " at least once "
> ------------------------------------
>
> Key: FLINK-24619
> URL: https://issues.apache.org/jira/browse/FLINK-24619
> Project: Flink
> Issue Type: Bug
> Components: Connectors/ RabbitMQ
> Reporter: szd
> Priority: Critical
>
> RMQSink
>
> question：message published without confirm， so , the message may be losed
>
> resolution : add a confirmListener or channel.waitForConfirm ?
>
> public void invoke(IN value) {
> channel.basicPublish(.....)
> }
>
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
