This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 17559d581e9 KAFKA-14645: Use plugin classloader when retrieving
connector plugin config definitions (#13148)
add eb7d5cbf15b MINOR: add startup timeouts to KRaft integration tests
(#13153)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/common/utils/Time.java | 29 +++++++
.../src/main/scala/kafka/server/BrokerServer.scala | 44 ++++------
.../main/scala/kafka/server/ControllerServer.scala | 17 ++--
core/src/main/scala/kafka/server/KafkaConfig.scala | 12 +--
.../java/kafka/testkit/KafkaClusterTestKit.java | 2 +
.../kafka/api/PlaintextAdminIntegrationTest.scala | 15 +++-
.../kafka/server/QuorumTestHarness.scala | 3 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 1 +
.../org/apache/kafka/server/util/Deadline.java | 72 +++++++++++++++++
.../org/apache/kafka/server/util/FutureUtils.java | 69 ++++++++++++++++
.../org/apache/kafka/server/util/DeadlineTest.java | 72 +++++++++++++++++
.../apache/kafka/server/util/FutureUtilsTest.java | 93 ++++++++++++++++++++++
12 files changed, 386 insertions(+), 43 deletions(-)
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/Deadline.java
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/FutureUtils.java
create mode 100644
server-common/src/test/java/org/apache/kafka/server/util/DeadlineTest.java
create mode 100644
server-common/src/test/java/org/apache/kafka/server/util/FutureUtilsTest.java
