Philip Nee created KAFKA-16023: ---------------------------------- Summary: PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding Key: KAFKA-16023 URL: https://issues.apache.org/jira/browse/KAFKA-16023 Project: Kafka Issue Type: Bug Reporter: Philip Nee
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. -- This message was sent by Atlassian Jira (v8.20.10#820010)