You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "szd (Jira)" <ji...@apache.org> on 2021/10/22 08:38:00 UTC

[jira] [Created] (FLINK-24619) rabbit not support " at least once "

szd created FLINK-24619:
---------------------------

             Summary: 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


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)