Skip to content

KAFKA-18488: Improve KafkaShareConsumerTest#18728

Merged
AndrewJSchofield merged 4 commits intoapache:trunkfrom
AndrewJSchofield:testVerifyFetchAndAcknowledgeSync
Jan 29, 2025
Merged

KAFKA-18488: Improve KafkaShareConsumerTest#18728
AndrewJSchofield merged 4 commits intoapache:trunkfrom
AndrewJSchofield:testVerifyFetchAndAcknowledgeSync

Conversation

@AndrewJSchofield
Copy link
Copy Markdown
Member

KafkaShareConsumer.testVerifyFetchAndAcknowledgeSync is occasionally failing. The underlying problem appears to be a ClassCastException in a request matcher.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@github-actions github-actions Bot added consumer tests Test fixes (including flaky tests) clients small Small PRs labels Jan 28, 2025
@AndrewJSchofield AndrewJSchofield added the KIP-932 Queues for Kafka label Jan 28, 2025
@github-actions github-actions Bot removed the small Small PRs label Jan 28, 2025
Copy link
Copy Markdown
Member

@lianetm lianetm left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks, the fix makes sense to me, just one comment

return request.data().groupId().equals(groupId) &&
request.data().shareSessionEpoch() == -1 &&
request.data().topics().isEmpty();
if (body instanceof ShareAcknowledgeRequest) {
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

should we include the same check in the testVerifyHeartbeats?

Copy link
Copy Markdown
Member

@lianetm lianetm left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks! LGTM.

@AndrewJSchofield AndrewJSchofield merged commit f960e20 into apache:trunk Jan 29, 2025
@AndrewJSchofield AndrewJSchofield deleted the testVerifyFetchAndAcknowledgeSync branch January 29, 2025 09:47
ijuma added a commit to ijuma/kafka that referenced this pull request Jan 30, 2025
…ibrdkafka-compressed-produce-fails

* apache-github/trunk:
  MINOR: prevent exception from HdrHistogram (apache#18674)
  KAFKA-18653: Fix mocks and potential thread leak issues causing silent RejectedExecutionException in share group broker tests (apache#18725)
  KAFKA-18646: Null records in fetch response breaks librdkafka (apache#18726)
  KAFKA-18619: New consumer topic metadata events should set requireMetadata flag (apache#18668)
  KAFKA-18488: Improve KafkaShareConsumerTest (apache#18728)
pdruley pushed a commit to pdruley/kafka that referenced this pull request Feb 12, 2025
Reviewers: Lianet Magrans <lmagrans@confluent.io>
manoj-mathivanan pushed a commit to manoj-mathivanan/kafka that referenced this pull request Feb 19, 2025
Reviewers: Lianet Magrans <lmagrans@confluent.io>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

clients consumer KIP-932 Queues for Kafka tests Test fixes (including flaky tests)

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants