[jira] [Commented] (FLINK-15821) Allow configuring Kafka partition / topic discovery in StateFun Kafka ingress
[
https://issues.apache.org/jira/browse/FLINK-15821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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)
[jira] [Commented] (FLINK-15819) Add more StateFun Kafka ingress features that are already available in FlinkKafkaConsumer
[
https://issues.apache.org/jira/browse/FLINK-15819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117573#comment-17117573
]
UnityLung commented on FLINK-15819:
---
Hi,
I would like to fix this.
Could you please assign it to me?
Thanks a lot.
> Add more StateFun Kafka ingress features that are already available in
> FlinkKafkaConsumer
> -
>
> Key: FLINK-15819
> URL: https://issues.apache.org/jira/browse/FLINK-15819
> Project: Flink
> Issue Type: New Feature
> Components: Stateful Functions
>Affects Versions: statefun-2.0.0
>Reporter: Tzu-Li (Gordon) Tai
>Priority: Major
>
> This is an umbrella JIRA to list all pending {{FlinkKafkaConsumer}} features
> that are reasonable to expose through Stateful Function's Kafka ingress.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-15820) Allow disabling / enabling auto offset committing to Kafka in StateFun Kafka ingress
[
https://issues.apache.org/jira/browse/FLINK-15820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117574#comment-17117574
]
UnityLung commented on FLINK-15820:
---
Hi,
I would like to fix this.
Could you please assign it to me?
Thanks a lot.
> Allow disabling / enabling auto offset committing to Kafka in StateFun Kafka
> ingress
>
>
> Key: FLINK-15820
> URL: https://issues.apache.org/jira/browse/FLINK-15820
> 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 supported in {{FlinkKafkaConsumer}}, so it would only be a
> matter of exposing it through the Stateful Functions Kafka ingress.
> It would be reasonable to support this with it being disabled by default, so
> that users do not always need to set the consumer group id and have a minimal
> setup to get started with using the ingress.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-17690) Python function wrapper omits docstr
[ https://issues.apache.org/jira/browse/FLINK-17690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113768#comment-17113768 ] UnityLung commented on FLINK-17690: --- Hi, I would like to fix this. Could you please assign it to me? Thanks a lot. > Python function wrapper omits docstr > > > Key: FLINK-17690 > URL: https://issues.apache.org/jira/browse/FLINK-17690 > Project: Flink > Issue Type: Improvement > Components: Stateful Functions >Reporter: Igal Shilman >Priority: Minor > > Statefun Python SDK has a connivance bind method, that wraps a functions. > The > [wrapper|https://github.com/apache/flink-statefun/blob/master/statefun-python-sdk/statefun/core.py#L182] > would omit the docstr of the wrapper function. A common practice would be to > use [https://docs.python.org/3/library/functools.html#functools.wraps] > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-16985) Specify job names for Stateful Functions examples
[ https://issues.apache.org/jira/browse/FLINK-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090676#comment-17090676 ] UnityLung commented on FLINK-16985: --- I would like to fix this. Could you please assign it to me? > Specify job names for Stateful Functions examples > - > > Key: FLINK-16985 > URL: https://issues.apache.org/jira/browse/FLINK-16985 > Project: Flink > Issue Type: Task > Components: Stateful Functions >Reporter: Tzu-Li (Gordon) Tai >Priority: Minor > Fix For: statefun-2.0.1 > > > The StateFun examples all use the default job name "StatefulFunctions". > It would be nice if they had specific job names, like "Greeter Example" or > "Shopping Cart Example", etc. -- This message was sent by Atlassian Jira (v8.3.4#803005)
