[jira] [Created] (FLINK-22165) How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv

[Shang Yuanchun (Jira)]

Spongebob created FLINK-22165:
---------------------------------

             Summary: How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv
                 Key: FLINK-22165
                 URL: https://issues.apache.org/jira/browse/FLINK-22165
             Project: Flink
          Issue Type: New Feature
          Components: API / DataStream
    Affects Versions: 1.12.2
         Environment: Flink 1.12.2

rabbitmq 3.8.4
            Reporter: Spongebob


Flink rabbitmq module provides source and sink function for rabbitmq. We can use the correlationId to deduplicate the checkpoints record, So can we set a correlationId for each message to sink into rabbitmq ? 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)