[jira] [Created] (FLINK-25693) User property 'auto.offset.reset' doesn't take precedence in case of scan.startup.mode= group-offsets

["Gaurav Miglani (Jira)" <ji...@apache.org>]

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)