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

Posted to user@flink.apache.org by mi...@ubs.com on 2019/03/13 13:26:58 UTC

Flink to MQ connector with checkpoint support for exctly once semantics

Hi,

Our Flink jobs need to read messages from IBM MQ  and write messages into IBM.
Just wonder if there are already some MQ connectors with two phase committee sink Function or Checkpoint Listener and checkpoint function implemented to support the exactly once semantics.
Many thanks in advance.
Min