[jira] [Commented] (FLINK-28185) "Invalid negative offset" when using OffsetsInitializer.timestamp(.)

[Mason Chen (Jira)]

Title: Message Title

Mason Chen commented on FLINK-28185   Re: "Invalid negative offset" when using OffsetsInitializer.timestamp(.) However, the proposal is a minor breaking change in behavior. From the source code: "the timestamp does not exist in the partition yet, we will just consume from the latest". So, the implementation is intended to return the latest offsets, if the timestamp cannot be found. +1 for the proposal, the semantics are clearer to me. Additionally, it is a bit confusing in this case, because the auto offset strategy doesn't really play a role here. Add Comment   This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9)