Tzu-Li (Gordon) Tai created FLINK-15818:
-------------------------------------------
Summary: Add Kafka ingress startup position config to YAML support
Key: FLINK-15818
URL: https://issues.apache.org/jira/browse/FLINK-15818
Project: Flink
Issue Type: New Feature
Components: Stateful Functions
Affects Versions: statefun-1.1
Reporter: Tzu-Li (Gordon) Tai
Assignee: Tzu-Li (Gordon) Tai
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
