RabbitMQ source was instantiated with usesCorrelationId set to true but a message was received with correlation id set to null

java.lang.NullPointerException: RabbitMQ source was instantiated with usesCorrelationId set to true but a message was received with correlation id set to null!
    at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:75)
    at org.apache.flink.streaming.connectors.rabbitmq.RMQSource.run(RMQSource.java:229)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
    at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:201)

DataStreamSource<String> dataStreamSource = env.addSource(new RMQSource<>(connectionConfig,
                "info",
                true,
                new SimpleStringSchema()))
                .setParallelism(1);