You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Tom Kalmijn (Jira)" <ji...@apache.org> on 2024/07/05 16:18:00 UTC

[jira] [Created] (KAFKA-17093) KafkaConsumer.seekToEnd should return LSO

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)