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)
