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)
