You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/16 05:18:00 UTC

[jira] [Created] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding

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)