You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by GitBox <gi...@apache.org> on 2020/11/25 17:24:48 UTC
[GitHub] [kafka] vvcephei opened a new pull request #9656: repro demonstrating non-owner commit
vvcephei opened a new pull request #9656:
URL: https://github.com/apache/kafka/pull/9656
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] vvcephei commented on pull request #9656: repro demonstrating non-owner commit
Posted by GitBox <gi...@apache.org>.
vvcephei commented on pull request #9656:
URL: https://github.com/apache/kafka/pull/9656#issuecomment-733844668
Not sure if this is expected or not, but it _seems_ wrong.
When this test fails, it prints:
```
cons1 owns it
Committed 11 with assignment [inputTopicLeft-0]
Committed 8 with assignment []
{inputTopicLeft-0=OffsetAndMetadata{offset=8, leaderEpoch=null, metadata='[]'}}
```
which indicates that the consumer that does _not_ own the partition is allowed to overwrite the owner's prior commit.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org