[ 
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)

Reply via email to