[
https://issues.apache.org/jira/browse/KAFKA-10683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226774#comment-17226774
]
Gary Russell edited comment on KAFKA-10683 at 11/5/20, 3:35 PM:
----------------------------------------------------------------
In addition, position() does not take the marker into account when
{noformat}
max.poll.records=1{noformat}
Even with read_committed isolation.
was (Author: grussell):
In addition, position() does not take the marker into account when
{noformat}max.poll.records=1{noformat}
> Consumer.position() Ignores Transaction Marker with read_uncommitted
> --------------------------------------------------------------------
>
> Key: KAFKA-10683
> URL: https://issues.apache.org/jira/browse/KAFKA-10683
> Project: Kafka
> Issue Type: Bug
> Components: clients, core
> Affects Versions: 2.6.0
> Reporter: Gary Russell
> Priority: Minor
>
> The workaround for https://issues.apache.org/jira/browse/KAFKA-6607# Says:
> {quote}
> or use `consumer.position()` that takes the commit marker into account and
> would "step over it")
> {quote}
> Note that this problem occurs with all consumers, not just Streams. We have
> implemented this solution in our project (as an option for those users
> concerned about the pseudo lag).
> We have discovered that this technique will only work with
> {code}isolation.level=read_committed{code} Otherwise, the
> {code}position(){code} call does not include the marker "record".
> https://github.com/spring-projects/spring-kafka/issues/1587#issuecomment-721899560
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
