You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Leo zhang (Jira)" <ji...@apache.org> on 2022/07/09 14:31:00 UTC

[jira] [Created] (FLINK-28475) kafka connector won't stop when the stopping offset is zero

Leo zhang created FLINK-28475:
---------------------------------

             Summary: kafka connector won't stop when the stopping offset is zero
                 Key: FLINK-28475
                 URL: https://issues.apache.org/jira/browse/FLINK-28475
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.15.0
            Reporter: Leo zhang


when use kafka connector in bounded mode,and the stopping offset hapends to be 0,the kafka connector won't stop,which is not expected.

I had traced the code, and found the stopping offset will be set to empty when it is zero, and an empty stopping offset means no stopping offset when serialized. This leads to a wrong execution.

I had fixed this in my personal branch,now I am logging this issue in Jira so that I can make merge request.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)