[BEAM-3454] Make Unbounded to Bounded conversions on IOs able to trigger on maxNumRecords and maxReadTime combined

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.3.0
• Component/s: io-java-amqp, io-java-jms, io-java-mqtt
• Assignee: Ryan Skraba
• Reporter: Ismaël Mejía
• Created: 11/Jan/18 10:58
• Updated: 24/Jul/20 20:19
• Resolved: 15/Jan/18 16:05

Description

Some Beam IOs expose the ability to turn an unbounded source into a bounded source. These IOs have two methods withMaxNumRecords and withMaxReadTime. Both methods are exclusive at runtime but they shouldn't be because BoundedReadFromUnboundedSource supports to combine the options so the first condition reached can stop the source if the user provides both..

There is already a ticket for KafkaIO and a fix for KinesisIO on the works, this ticket is to add this to the other Sources (e.g. MqttIO, JmsIO, etc).

Issue Links

• relates to: BEAM-1847 KafkaIO can't specify both max records and max duration.
• links to: GitHub Pull Request #4415