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)