[KAFKA-16023] PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding

• Type: Test
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 3.8.0
• Component/s: clients, consumer
• Labels: consumer-threading-refactor integration-tests timeout
• Assignee: Kirk True
• Reporter: Philip Nee
• Created: 16/Dec/23 05:17
• Updated: 20/Feb/24 20:30
• Resolved: 20/Feb/24 20:30

Description

Several tests in PlaintextConsumerTest.scala (such as testPerPartitionLagMetricsCleanUpWithSubscribe) uses:

assertEquals(1, listener.callsToAssigned, "should be assigned once")

However, as the timing for reconciliation completion is not deterministic due to asynchronous processing. We actually need to wait until the condition to happen.

However, another issue is the timeout - some of these tasks might not complete within the 600ms timeout, so the tests are deemed to be flaky.

Issue Links

• links to: GitHub Pull Request #15025