fix: The actual position has to be requested from the consumer
authorKai Moritz <kai@juplo.de>
Sun, 24 Sep 2023 19:39:01 +0000 (21:39 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 28 Jan 2024 17:59:08 +0000 (18:59 +0100)
commitf2f547425d59c5c0535e88268769e05136b7728e
tree492e57a2558023f53b31c56249bbb2c18a3e16ef
parent681d57ac2d1a3dd44a3753dc34d2d0b9e3e55aee
fix: The actual position has to be requested from the consumer

* If the last seen offset and the current offset differ, although the
  partition did not contain any messages between this offsets, the loading
  process got stuck, because the position never advanced.
* Therefore, the actual position, that is compared against the read
  end-offset, has to be requested from the consumer.
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java