Gergo L��p created KAFKA-14442:
----------------------------------
Summary: GlobalKTable restoration waits requestTimeout during
application restart
Key: KAFKA-14442
URL: https://issues.apache.org/jira/browse/KAFKA-14442
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 3.0.0
Reporter: Gergo L��p
Using "exactly_once_beta" the highWatermark "skips" an offset after a
transaction but in this case the global .checkpoint file contains different
value (smaller by 1) than the highWatermark.
During restoration because of the difference between the checkpoint and
highWatermark a poll will be attempted but sometimes there is no new record on
the partition and the GlobalStreamThread has to wait for the requestTimeout to
continue.
If there is any new record on the partition the problem does not occure.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
