Skip to content

Conversation

@smjn
Copy link
Collaborator

@smjn smjn commented Nov 17, 2025

  • A couple of additional share consumer tests to check dual ack with
    renew and poll behavior with renew acks piggybacked.

Reviewers: Andrew Schofield aschofield@confluent.io

@github-actions github-actions bot added triage PRs from the community tests Test fixes (including flaky tests) clients labels Nov 17, 2025
@smjn smjn requested a review from apoorvmittal10 November 17, 2025 10:38
@smjn smjn added KIP-932 Queues for Kafka ci-approved and removed triage PRs from the community labels Nov 17, 2025
@smjn smjn changed the title KAFKA-19845: 2/N Addition share consumers test. KAFKA-19845: 2/N Additional share consumers test. Nov 17, 2025
@smjn smjn changed the title KAFKA-19845: 2/N Additional share consumers test. KAFKA-19845: 2/N Additional share consumers tests. Nov 17, 2025
@smjn smjn marked this pull request as draft November 17, 2025 10:59
@smjn smjn marked this pull request as ready for review November 17, 2025 11:15
@github-actions github-actions bot added the small Small PRs label Nov 17, 2025
@github-actions github-actions bot removed the small Small PRs label Nov 17, 2025
@smjn smjn closed this Nov 17, 2025
@smjn smjn reopened this Nov 17, 2025
@github-actions github-actions bot added the triage PRs from the community label Nov 17, 2025
@smjn smjn removed the triage PRs from the community label Nov 18, 2025
}

private void verifyYammerMetricCount(String filterString, int count) {
com.yammer.metrics.core.Metric renewAck = KafkaYammerMetrics.defaultRegistry().allMetrics().entrySet().stream()
Copy link
Member

Choose a reason for hiding this comment

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

nit: This isn't really a renewAck because the filter string is an argument. However, that's such a tiny nit that we can fix it next time through this file.

@AndrewJSchofield AndrewJSchofield merged commit 81d86e5 into apache:trunk Nov 18, 2025
26 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

ci-approved clients 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