[ https://issues.apache.org/jira/browse/KAFKA-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864081#comment-17864081 ]
Andrew Schofield commented on KAFKA-17093: ------------------------------------------ [~tkalmijn] I'll work on writing a simple Kafka client application that very carefully lines up the topic with a predictable set of records and then uses the consumer methods in question. I'll share the code once I've finished the investigations. > KafkaConsumer.seekToEnd should return LSO > ------------------------------------------ > > Key: KAFKA-17093 > URL: https://issues.apache.org/jira/browse/KAFKA-17093 > Project: Kafka > Issue Type: Bug > Components: clients, consumer > Affects Versions: 3.6.1 > Environment: Ubuntu, IntelliJ, Scala "org.apache.kafka" % > "kafka-clients" % "3.6.1" > Reporter: Tom Kalmijn > Assignee: Andrew Schofield > Priority: Major > > > 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)