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)