Tom Kalmijn created KAFKA-17093:
-----------------------------------
Summary: KafkaConsumer.seekToEnd should return LSO
Key: KAFKA-17093
URL: https://issues.apache.org/jira/browse/KAFKA-17093
Project: Kafka
Issue Type: Bug
Components: consumer
Affects Versions: 3.6.1
Environment: Ubuntu, IntelliJ, Scala "org.apache.kafka" %
"kafka-clients" % "3.6.1"
Reporter: Tom Kalmijn
Expected
When using a transactional producer then the method
KafkaConsumer.seekToEnd(...) of a consumer configured with isolation level
"read_committed" should return the LSO.
Observed
The offset returned is always the actual last offset of the partition, which is
not the LSO if the latest offsets are occupied by transaction markers.
Also see this Slack thread:
https://confluentcommunity.slack.com/archives/C499EFQS0/p1720088282557559
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
