[jira] [Created] (FLINK-15818) Add Kafka ingress startup position config to YAML support

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-15818) Add Kafka ingress startup position config to YAML support

Shang Yuanchun (Jira)
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)