This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 247132569e7 KAFKA-16912 Migrate
ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest
(#16234)
add d6cd83e2fb2 KAFKA-16200: Enforce that RequestManager implementations
respect user-provided timeout (#16031)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/CommitRequestManager.java | 133 ++++++++----------
.../consumer/internals/MembershipManagerImpl.java | 4 +-
.../consumer/internals/NetworkClientDelegate.java | 11 +-
.../consumer/internals/RequestManagers.java | 1 +
.../consumer/internals/TimedRequestState.java | 71 ++++++++++
.../internals/TopicMetadataRequestManager.java | 53 +++----
.../events/CompletableApplicationEvent.java | 1 +
.../internals/CommitRequestManagerTest.java | 153 +++++++++++++--------
.../consumer/internals/ConsumerTestBuilder.java | 2 +-
.../consumer/internals/TimedRequestStateTest.java | 96 +++++++++++++
.../internals/TopicMetadataRequestManagerTest.java | 1 +
.../kafka/api/AbstractConsumerTest.scala | 7 +-
.../kafka/api/PlaintextConsumerPollTest.scala | 13 ++
.../test/scala/unit/kafka/utils/TestUtils.scala | 5 +-
.../tiered/storage/TieredStorageTestContext.java | 3 +-
15 files changed, 382 insertions(+), 172 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TimedRequestState.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/TimedRequestStateTest.java
