[
https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-16023:
-------------------------------
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.
was:
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.
> 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: Sub-task
> Reporter: Philip Nee
> Priority: Major
>
> 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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
