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)
