Gaurav Miglani created FLINK-25693:
--------------------------------------
Summary: User property 'auto.offset.reset' doesn't take precedence
in case of scan.startup.mode= group-offsets
Key: FLINK-25693
URL: https://issues.apache.org/jira/browse/FLINK-25693
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.13.3, 1.14.0
Reporter: Gaurav Miglani
If we declare a Kafka table with `scan.startup.mode`= group-offset along with
Kafka auto.offset.reset policy, user property doesn't take precedence. I think
there is an issue with the 2 files.
#
[KafkaDynamicSource.java|https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java#L396]
-> Line no. 396
#
[OffsetsInitializer.java|https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java#L108]
-> Line No. 108
I think in the case of group offset, we need to check if the user has
configured auto.offset.reset parameter. If yes, we should set
OffsetResetStrategy as per.
SO error:
[https://stackoverflow.com/questions/70756264/flink-kafka-sql-set-auto-offset-reset]
Let me know if it is really an issue, I will be happy to work on and fix this
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
