[
https://issues.apache.org/jira/browse/FLINK-15818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-15818:
----------------------------------------
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.
was:
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.
> 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
> Priority: Major
>
> 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)
