Kirk True created KAFKA-15638: --------------------------------- Summary: Investigate ConsumerNetworkThread's testPollResultTimer Key: KAFKA-15638 URL: https://issues.apache.org/jira/browse/KAFKA-15638 Project: Kafka Issue Type: Sub-task Components: clients, consumer Reporter: Kirk True Assignee: Kirk True
Thanks for the reply. I still don't quite understand the test. Why do we duplicate the following code both inside and outside of {{{}setWakeupHook{}}}? {code:java} networkClientDelegate.disconnectAsync(readReplica); networkClientDelegate.poll(time.timer(0)); {code} MockClient is only woken up through {{{}networkClientDelegate.disconnectAsync{}}}. -- This message was sent by Atlassian Jira (v8.20.10#820010)