[ https://issues.apache.org/jira/browse/FLINK-15821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117575#comment-17117575 ]
UnityLung commented on FLINK-15821: ----------------------------------- Hi, I would like to fix this. Could you please assign it to me? Thanks a lot. > Allow configuring Kafka partition / topic discovery in StateFun Kafka ingress > ----------------------------------------------------------------------------- > > Key: FLINK-15821 > URL: https://issues.apache.org/jira/browse/FLINK-15821 > Project: Flink > Issue Type: Sub-task > Components: Stateful Functions > Affects Versions: statefun-2.0.0 > Reporter: Tzu-Li (Gordon) Tai > Priority: Major > > This is already implemented in the {{FlinkKafkaConsumer}}, so it would only > be a matter of exposing it through Stateful Function's Kafka ingress. > Proposed API: > {code} > KafkaIngressBuilder#withTopics(java.util.regex.Pattern regexPattern) > KafkaIngressBuilder#enableDiscovery(java.time.Duration discoveryInterval) > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)