[jira] [Created] (FLINK-15820) Allow disabling / enabling auto offset committing to Kafka in StateFun Kafka ingress

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

[jira] [Created] (FLINK-15820) Allow disabling / enabling auto offset committing to Kafka in StateFun Kafka ingress

Shang Yuanchun (Jira)
Tzu-Li (Gordon) Tai created FLINK-15820:
-------------------------------------------

             Summary: 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-1.1
            Reporter: Tzu-Li (Gordon) Tai


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)