[
https://issues.apache.org/jira/browse/FLINK-25693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477968#comment-17477968
]
Fabian Paul commented on FLINK-25693:
-------------------------------------
[~ruanhang1993] [~renqs] can you take a look at this?
> 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.14.0, 1.13.3
> Reporter: Gaurav Miglani
> Priority: Major
>
> 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)
