[ https://issues.apache.org/jira/browse/KAFKA-17103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhengke zhou reassigned KAFKA-17103: ------------------------------------ Assignee: zhengke zhou > MockClient tight loops when no metadata is present in KafkaProducerTest > ----------------------------------------------------------------------- > > Key: KAFKA-17103 > URL: https://issues.apache.org/jira/browse/KAFKA-17103 > Project: Kafka > Issue Type: Test > Components: clients > Reporter: Greg Harris > Assignee: zhengke zhou > Priority: Minor > Labels: newbie > > MockClient can throw this exception: > {noformat} > [2024-07-09 13:19:33,574] ERROR [Producer clientId=producer-1] Uncaught error > in kafka producer I/O thread: > (org.apache.kafka.clients.producer.internals.Sender:253) > java.lang.IllegalStateException: No previous metadata update to use > at > org.apache.kafka.clients.MockClient$DefaultMockMetadataUpdater.updateWithCurrentMetadata(MockClient.java:700) > at org.apache.kafka.clients.MockClient.poll(MockClient.java:323) > at > org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:349) > at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:251) > at java.base/java.lang.Thread.run(Thread.java:829){noformat} > This happens whenever the MockClient.DefaultMockMetadataUpdater#lastUpdate > variable is null, which is the case whenever there has not been any mock > metadata update. > In practice, this appears to happen in > KafkaProducerTest#testTopicExpiryInMetadata, > KafkaProducerTest#testTopicRefreshInMetadata, > KafkaProducerTest#testTopicNotExistingInMetadata. These three tests also use > busy-waiting to have another thread wait for the metadata update request and > then provide the metadata update. > We should find some mechanism to allow mocking these metadata updates that > avoids this busy waiting/tight looping pattern, as it introduces an > opportunity for nondeterminism and wastes CPU cycles. > The solution should remove any usage of Thread.sleep/Utils.sleep/Time.SYSTEM. > Ideally the solution wouldn't require an additional test thread, but this is > optional. -- This message was sent by Atlassian Jira (v8.20.10#820010)