[FLINK-15818] Add Kafka ingress startup position config to YAML support

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: statefun-2.0.0
• Fix Version/s: statefun-2.0.0
• Component/s: Stateful Functions
• Labels: pull-request-available
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 31/Jan/20 04:37
• Updated: 31/Jan/20 16:09
• Resolved: 31/Jan/20 16:09

Description

With FLINK-15769, we've added startup position configuration to the Java Kafka Ingress.
The same functionality should also be added to the YAML support.
Part of this work should also cover unifying source creation logic between the ProtobufKafkaSourceProvider and KafkaSourceProvider so that configuration validation is shared.

Issue Links

• links to: GitHub Pull Request #6