Mike Lynch created FLINK-25082:
----------------------------------
Summary: RMQSource is not parallel
Key: FLINK-25082
URL: https://issues.apache.org/jira/browse/FLINK-25082
Project: Flink
Issue Type: Bug
Components: Connectors/ RabbitMQ
Reporter: Mike Lynch
The official
[documentation|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/rabbitmq/]
states that{{ RMQSource}} can have at-least-once processing when "when
checkpointing is enabled, but correlation ids are not used or the source is
parallel." However, as {{RMQSource}} does not implement
{{{}ParallelSourceFunction{}}}, {{StreamExecutionEnvironment}} will throw an
exception whenever parallelism is set to a value higher than 1.
Either the documentation should be corrected or {{RMQSource}} should implement
{{{}ParallelSourceFunction{}}}.
Implementing it seems like it should be fairly easy and I'd be willing to
submit a patch, but as I'm new to the Flink code base I'm not sure if there
would be unexpected side effects. If I can get feedback from more experienced
contributors, I'll submit a patch in the near future.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
